Toggle navigation
Home
java.sql.PreparedStatement to org.apache.flink.contrib.streaming.state.ShardedConnection.ShardedStatement
No. of Instances - 2
No. of Commits - 1
No. of Projects - {'flink'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Jdk -> Internal
Mapping:
Rename Variable
selectStatement
to
selectStatements
selectStatement
to
selectStatements
selectStatement
to
selectStatements
insertStatement
to
insertStatements
insertStatement
to
insertStatements
insertStatement
to
insertStatements
Add or Remove Method invocation
con
to
dbAdapter.prepareKeyLookup(kvStateId)
dbAdapter.prepareKVCheckpointInsert(kvStateId,con)
to
cons.prepareStatement(dbAdapter.prepareKVCheckpointInsert(kvStateId))
dbAdapter.prepareKeyLookup(kvStateId,con)
to
cons.prepareStatement(dbAdapter.prepareKeyLookup(kvStateId))
con
to
dbAdapter.prepareKVCheckpointInsert(kvStateId)
dbAdapter.prepareKVCheckpointInsert(kvStateId,con)
to
cons.prepareStatement(dbAdapter.prepareKVCheckpointInsert(kvStateId))
dbAdapter.prepareKeyLookup(kvStateId,con)
to
cons.prepareStatement(dbAdapter.prepareKeyLookup(kvStateId))
Update Anonymous class
{ public Void call() throws Exception { dbAdapter.createKVStateTable(kvStateId,con); insertStatement=dbAdapter.prepareKVCheckpointInsert(kvStateId,con); selectStatement=dbAdapter.prepareKeyLookup(kvStateId,con); return null; } }
to
{ public Void call() throws Exception { for ( Connection con : cons.connections()) { dbAdapter.createKVStateTable(kvStateId,con); } insertStatements=cons.prepareStatement(dbAdapter.prepareKVCheckpointInsert(kvStateId)); selectStatements=cons.prepareStatement(dbAdapter.prepareKeyLookup(kvStateId)); return null; } }
{ public Void call() throws Exception { dbAdapter.createKVStateTable(kvStateId,con); insertStatement=dbAdapter.prepareKVCheckpointInsert(kvStateId,con); selectStatement=dbAdapter.prepareKeyLookup(kvStateId,con); return null; } }
to
{ public Void call() throws Exception { for ( Connection con : cons.connections()) { dbAdapter.createKVStateTable(kvStateId,con); } insertStatements=cons.prepareStatement(dbAdapter.prepareKVCheckpointInsert(kvStateId)); selectStatements=cons.prepareStatement(dbAdapter.prepareKeyLookup(kvStateId)); return null; } }