Toggle navigation
Home
java.sql.Connection to org.apache.flink.contrib.streaming.state.ShardedConnection
No. of Instances - 9
No. of Commits - 1
No. of Projects - {'flink'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Jdk -> Internal
Mapping:
Add or Remove Method invocation
con
to
con.getFirst()
con
to
con.getFirst()
dbConfig.createConnection(shardIndex)
to
dbConfig.createShardedConnection()
con
to
connections.getFirst()
con
to
dbAdapter.prepareKVCheckpointInsert(kvStateId)
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))
Rename Variable
con
to
connections
con
to
connections
con
to
connections
con
to
connections
con
to
connections
con
to
connections
getConnection
to
getConnections
con
to
cons
con
to
cons
con
to
cons
con
to
cons
con
to
cons
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; } }