Toggle navigation
Home
org.apache.flink.streaming.connectors.kinesis.model.KinesisStreamShard to org.apache.flink.streaming.connectors.kinesis.model.StreamShardHandle
No. of Instances - 59
No. of Commits - 1
No. of Projects - {'flink'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Update Class Instacne Creation
new KinesisStreamShardState(restoredState.getKey(),new SequenceNumber(restoredState.getValue()))
to
new KinesisStreamShardState(KinesisDataFetcher.createKinesisStreamShardV2(restoredState.getKey()),restoredState.getKey(),new SequenceNumber(restoredState.getValue()))
new KinesisStreamShardState(restoredShard.getKey(),restoredShard.getValue())
to
new KinesisStreamShardState(KinesisDataFetcher.createKinesisStreamShardV2(restoredShard.getKey()),restoredShard.getKey(),restoredShard.getValue())
new KinesisStreamShardState(restoredState.getKey(),new SequenceNumber(restoredState.getValue()))
to
new KinesisStreamShardState(KinesisDataFetcher.createKinesisStreamShardV2(restoredState.getKey()),restoredState.getKey(),new SequenceNumber(restoredState.getValue()))
new KinesisStreamShardState(restoredState.getKey(),new SequenceNumber(restoredState.getValue()))
to
new KinesisStreamShardState(KinesisDataFetcher.createKinesisStreamShardV2(restoredState.getKey()),restoredState.getKey(),new SequenceNumber(restoredState.getValue()))
new KinesisStreamShardState(fakeToBeConsumedShard,new SequenceNumber("fakeStartingState"))
to
new KinesisStreamShardState(KinesisDataFetcher.createKinesisStreamShardV2(fakeToBeConsumedShard),fakeToBeConsumedShard,new SequenceNumber("fakeStartingState"))
new KinesisStreamShardState(restoredShard.getKey(),restoredShard.getValue())
to
new KinesisStreamShardState(KinesisDataFetcher.createKinesisStreamShardV2(restoredShard.getKey()),restoredShard.getKey(),restoredShard.getValue())
new KinesisStreamShardState(restoredShard.getKey(),restoredShard.getValue())
to
new KinesisStreamShardState(KinesisDataFetcher.createKinesisStreamShardV2(restoredShard.getKey()),restoredShard.getKey(),restoredShard.getValue())
new KinesisStreamShardState(restoredState.getKey(),new SequenceNumber(restoredState.getValue()))
to
new KinesisStreamShardState(KinesisDataFetcher.createKinesisStreamShardV2(restoredState.getKey()),restoredState.getKey(),new SequenceNumber(restoredState.getValue()))
new KinesisStreamShardState(restoredShard.getKey(),restoredShard.getValue())
to
new KinesisStreamShardState(KinesisDataFetcher.createKinesisStreamShardV2(restoredShard.getKey()),restoredShard.getKey(),restoredShard.getValue())
new KinesisStreamShardState(restoredShard.getKey(),restoredShard.getValue())
to
new KinesisStreamShardState(KinesisDataFetcher.createKinesisStreamShardV2(restoredShard.getKey()),restoredShard.getKey(),restoredShard.getValue())
new KinesisStreamShardState(fakeToBeConsumedShard,new SequenceNumber("fakeStartingState"))
to
new KinesisStreamShardState(KinesisDataFetcher.createKinesisStreamShardV2(fakeToBeConsumedShard),fakeToBeConsumedShard,new SequenceNumber("fakeStartingState"))
Add or Remove Method invocation
Tuple2.of(state.getKey(),state.getValue())
to
Tuple2.of(KinesisDataFetcher.createKinesisStreamShardV2(state.getKey()),state.getValue())
Tuple2.of(state.getKey(),state.getValue())
to
Tuple2.of(KinesisDataFetcher.createKinesisStreamShardV2(state.getKey()),state.getValue())
Tuple2.of(state.getKey(),state.getValue())
to
Tuple2.of(KinesisDataFetcher.createKinesisStreamShardV2(state.getKey()),state.getValue())
Tuple2.of(state.getKey(),state.getValue())
to
Tuple2.of(KinesisDataFetcher.createKinesisStreamShardV2(state.getKey()),state.getValue())
Cascading Type Change (Similar)
KinesisStreamShard
to
StreamShardHandle
KinesisStreamShard
to
StreamShardHandle
KinesisStreamShard
to
StreamShardHandle
KinesisStreamShard
to
StreamShardHandle
KinesisStreamShard
to
StreamShardHandle
KinesisStreamShard
to
StreamShardHandle
KinesisStreamShard
to
StreamShardHandle
KinesisStreamShard
to
StreamShardHandle
KinesisStreamShard
to
StreamShardHandle
KinesisStreamShard
to
StreamShardHandle
KinesisStreamShard
to
StreamShardHandle
KinesisStreamShard
to
StreamShardHandle
KinesisStreamShard
to
StreamShardHandle
KinesisStreamShard
to
StreamShardHandle
KinesisStreamShard
to
StreamShardHandle
KinesisStreamShard
to
StreamShardHandle
KinesisStreamShard
to
StreamShardHandle
KinesisStreamShard
to
StreamShardHandle
KinesisStreamShard
to
StreamShardHandle
KinesisStreamShard
to
StreamShardHandle
KinesisStreamShard
to
StreamShardHandle
KinesisStreamShard
to
StreamShardHandle
KinesisStreamShard
to
StreamShardHandle
KinesisStreamShard
to
StreamShardHandle
KinesisStreamShard
to
StreamShardHandle
KinesisStreamShard
to
StreamShardHandle
KinesisStreamShard
to
StreamShardHandle
KinesisStreamShard
to
StreamShardHandle
KinesisStreamShard
to
StreamShardHandle
Update argument list (Class Instance Creation)
KinesisStreamShardState
to
KinesisStreamShardState