Java 类com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessor 实例源码

/**
 * {@inheritDoc}
 */
public IRecordProcessor createProcessor() {
    try {
        LOG.info("Creating new Managed Client Processor");
        ManagedClientProcessor p = this.managedProcessor.copy();
        createdProcessors.put(p.toString(), p);
        return p;
    } catch (Exception e) {
        LOG.error(e);
        return null;
    }
}

@Override
public IRecordProcessor createProcessor() {
    logger.info("Creating RecordProcessor");
    if (recordProcessor == null) {
        recordProcessor = new RecordProcessor();
    }
    return recordProcessor;
}

@Override
public IRecordProcessor createProcessor() {
    try {
        IBuffer<T> buffer = pipeline.getBuffer(configuration);
        IEmitter<U> emitter = pipeline.getEmitter(configuration);
        ITransformerBase<T, U> transformer = pipeline.getTransformer(configuration);
        IFilter<T> filter = pipeline.getFilter(configuration);
        KinesisConnectorRecordProcessor<T, U> processor =
                new KinesisConnectorRecordProcessor<T, U>(buffer, filter, emitter, transformer, configuration);
        return processor;
    } catch (Throwable t) {
        throw new RuntimeException(t);
    }
}

@Override
public IRecordProcessor createProcessor() {
    return new FlumeSourceRecordProcessor(chProcessor,
                                          serializer,
                                          backOffTimeInMillis,
                                          numberRetries,
                                          checkpointIntervalMillis);
}

/**
 * {@inheritDoc}
 */
public IRecordProcessor createProcessor() {
    try {
        // every time we create a new processor instance, we have to embed a
        // new instance of the AggregatorGroup, to eliminate any thread
        // contention
        return new AggregatorProcessor(new AggregatorGroup(this.aggregators));
    } catch (Exception e) {
        LOG.error(e);
        return null;
    }
}

/**
 * {@inheritDoc}
 */
public IRecordProcessor createProcessor() {
    try {
        LOG.info("Creating new Managed Client Processor");
        ManagedClientProcessor p = this.managedProcessor.copy();
        createdProcessors.put(p.toString(), p);
        return p;
    } catch (Exception e) {
        LOG.error(e);
        return null;
    }
}

@Override
public IRecordProcessor createProcessor() {
    return new EventRecordProcessor(receiver, workerId,
                            new KinesisCheckpointState(checkpointInterval));
}

@Override
public IRecordProcessor createProcessor() {
    return new KafkaForwardingStreamsRecordProcessor(props, topic);
}

@Override
public IRecordProcessor createProcessor() {
    return new Processor();
}

/**
 * {@inheritDoc}
 */
public IRecordProcessor createProcessor() {
    return new KinesisRecordProcessor(redisEndpoint, redisPort);
}

@Override
public IRecordProcessor createProcessor() {
    return new StreamsRecordProcessor(cache);
}

@Override
public IRecordProcessor createProcessor() {
    return new KinesisRawEventRecordProcessor(this.topic, this.handler, this.mapper);
}

@Override
public IRecordProcessor createProcessor() {
    return new RecordProcessor(_buffer);
}

@Override
public IRecordProcessor createProcessor() {
    return new RecordProcessor(_buffer);
}

@Override
public IRecordProcessor createProcessor() {
    AmazonDynamoDBClient dynamoDBClient = new AmazonDynamoDBClient(dynamoDBCredentials, new ClientConfiguration());
    dynamoDBClient.setEndpoint(dynamoDBEndpoint);
    return new StreamsRecordProcessor(dynamoDBClient, tableName);
}

/**
 * {@inheritDoc}
 */
@Override
public IRecordProcessor createProcessor() {
    return new TweetamoRecordProcessor();
}