kinesis-lib/src/main/java/com/streamsets/pipeline/stage/origin/kinesis/StreamSetsRecordProcessor.java
@Override
  public void initialize(InitializationInput initializationInput) {
    shardId = initializationInput.getShardId();
    if (LOG.isDebugEnabled()) {
      LOG.debug("Initializing record processor at: {}", initializationInput.getExtendedSequenceNumber().toString());
      LOG.debug("Initializing record processor for shard: {}", shardId);
    }
  }
@Override
  public void initialize(InitializationInput initializationInput) {
    shardId = initializationInput.getShardId();
    if (LOG.isDebugEnabled()) {
      LOG.debug("Initializing record processor at: {}", initializationInput.getExtendedSequenceNumber().toString());
      LOG.debug("Initializing record processor for shard: {}", shardId);
    }
  }
@ Override public void initialize ( InitializationInput initializationInput ) { shardId = initializationInput . getShardId ( ) ; if ( LOG . isDebugEnabled ( ) ) { LOG . debug ( "Initializing record processor at: {}" , initializationInput . getExtendedSequenceNumber ( ) . toString ( ) ) ; LOG . debug ( "Initializing record processor for shard: {}" , shardId ) ; } }
{@inheritDoc}
{