Toggle navigation
Home
org.apache.flink.streaming.connectors.kinesis.model.KinesisStreamShard to org.apache.flink.streaming.connectors.kinesis.model.KinesisStreamShardV2
No. of Instances - 30
No. of Commits - 1
No. of Projects - {'flink'}
Hierarchy/Composition: SIBLING
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Add or Remove Method invocation
Tuple2.of(state.getKey(),state.getValue())
to
Tuple2.of(KinesisDataFetcher.createKinesisStreamShardV2(state.getKey()),state.getValue())
Tuple2.of(new StreamShardHandle("fakeStream",new Shard().withShardId(KinesisShardIdGenerator.generateFromShardOrder(0))),new SequenceNumber("1"))
to
Tuple2.of(KinesisDataFetcher.createKinesisStreamShardV2(new StreamShardHandle("fakeStream",new Shard().withShardId(KinesisShardIdGenerator.generateFromShardOrder(0)))),new SequenceNumber("1"))
Tuple2.of(new StreamShardHandle("fakeStream",new Shard().withShardId(KinesisShardIdGenerator.generateFromShardOrder(1))),new SequenceNumber("1"))
to
Tuple2.of(KinesisDataFetcher.createKinesisStreamShardV2(new StreamShardHandle("fakeStream",new Shard().withShardId(KinesisShardIdGenerator.generateFromShardOrder(1)))),new SequenceNumber("1"))
Tuple2.of(new StreamShardHandle("fakeStream",new Shard().withShardId(KinesisShardIdGenerator.generateFromShardOrder(2))),new SequenceNumber("1"))
to
Tuple2.of(KinesisDataFetcher.createKinesisStreamShardV2(new StreamShardHandle("fakeStream",new Shard().withShardId(KinesisShardIdGenerator.generateFromShardOrder(2)))),new SequenceNumber("1"))
Tuple2.of(new StreamShardHandle("fakeStream",new Shard().withShardId(KinesisShardIdGenerator.generateFromShardOrder(3))),new SequenceNumber("1"))
to
Tuple2.of(KinesisDataFetcher.createKinesisStreamShardV2(new StreamShardHandle("fakeStream",new Shard().withShardId(KinesisShardIdGenerator.generateFromShardOrder(3)))),new SequenceNumber("1"))
KinesisDataFetcher.isThisSubtaskShouldSubscribeTo(entry.getKey(),getRuntimeContext().getNumberOfParallelSubtasks(),getRuntimeContext().getIndexOfThisSubtask())
to
KinesisDataFetcher.isThisSubtaskShouldSubscribeTo(KinesisDataFetcher.createStreamShardHandle(entry.getKey()),getRuntimeContext().getNumberOfParallelSubtasks(),getRuntimeContext().getIndexOfThisSubtask())
sequenceNumsToRestore.get(shard)
to
sequenceNumsToRestore.get(kinesisStreamShard)
Tuple2.of(new StreamShardHandle("fakeStream1",new Shard().withShardId(KinesisShardIdGenerator.generateFromShardOrder(0))),new SequenceNumber("1"))
to
Tuple2.of(KinesisDataFetcher.createKinesisStreamShardV2(new StreamShardHandle("fakeStream1",new Shard().withShardId(KinesisShardIdGenerator.generateFromShardOrder(0)))),new SequenceNumber("1"))
Tuple2.of(state.getKey(),state.getValue())
to
Tuple2.of(KinesisDataFetcher.createKinesisStreamShardV2(state.getKey()),state.getValue())
Tuple2.of(new StreamShardHandle("fakeStream1",new Shard().withShardId(KinesisShardIdGenerator.generateFromShardOrder(0))),new SequenceNumber("12"))
to
Tuple2.of(KinesisDataFetcher.createKinesisStreamShardV2(new StreamShardHandle("fakeStream1",new Shard().withShardId(KinesisShardIdGenerator.generateFromShardOrder(0)))),new SequenceNumber("12"))
Tuple2.of(new StreamShardHandle("fakeStream1",new Shard().withShardId(KinesisShardIdGenerator.generateFromShardOrder(1))),new SequenceNumber("11"))
to
Tuple2.of(KinesisDataFetcher.createKinesisStreamShardV2(new StreamShardHandle("fakeStream1",new Shard().withShardId(KinesisShardIdGenerator.generateFromShardOrder(1)))),new SequenceNumber("11"))
Tuple2.of(new StreamShardHandle("fakeStream1",new Shard().withShardId(KinesisShardIdGenerator.generateFromShardOrder(2))),new SequenceNumber("31"))
to
Tuple2.of(KinesisDataFetcher.createKinesisStreamShardV2(new StreamShardHandle("fakeStream1",new Shard().withShardId(KinesisShardIdGenerator.generateFromShardOrder(2)))),new SequenceNumber("31"))
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 (Different)
KinesisStreamShard
to
StreamShardHandle
KinesisStreamShard
to
StreamShardHandle
KinesisStreamShard
to
StreamShardHandle
KinesisStreamShard
to
StreamShardHandle
KinesisStreamShard
to
StreamShardHandle
KinesisStreamShard
to
StreamShardHandle
KinesisStreamShard
to
StreamShardHandle
KinesisStreamShard
to
StreamShardHandle
Wrap or Un-wrap
put
to
put