question: implement operator interface . concode_field_sep String endPoint concode_elem_sep Logger logger concode_elem_sep int batchSize concode_elem_sep String secretKey concode_elem_sep String accessKey concode_elem_sep boolean isBatchProcessing concode_elem_sep DefaultInputPort<T> inputPort concode_elem_sep int sendCount concode_elem_sep String streamName concode_elem_sep AmazonKinesisClient client concode_elem_sep List<PutRecordsRequestEntry> putRecordsRequestEntryList concode_field_sep String getSecretKey concode_elem_sep void setStreamName concode_elem_sep void endWindow concode_elem_sep void setClient concode_elem_sep void flushRecords concode_elem_sep byte[] getRecord concode_elem_sep void setBatchProcessing concode_elem_sep void teardown concode_elem_sep void setSecretKey concode_elem_sep void setEndPoint concode_elem_sep void committed concode_elem_sep void process concode_elem_sep String getStreamName concode_elem_sep boolean isBatchProcessing concode_elem_sep Pair<String,V> tupleToKeyValue concode_elem_sep void addRecord concode_elem_sep void checkpointed concode_elem_sep void processTuple concode_elem_sep int getBatchSize concode_elem_sep void setBatchSize concode_elem_sep void beginWindow concode_elem_sep String getEndPoint concode_elem_sep void setAccessKey concode_elem_sep void setup concode_elem_sep String getAccessKey
target: void function ( long arg0 ) { if ( isBatchProcessing && putRecordsRequestEntryList . size ( ) != 0 ) { try { flushRecords ( ) ; } catch ( AmazonClientException loc0 ) { throw new RuntimeException ( loc0 ) ; } } }