本文整理汇总了Java中com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessor类的典型用法代码示例。如果您正苦于以下问题:Java IRecordProcessor类的具体用法?Java IRecordProcessor怎么用?Java IRecordProcessor使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
IRecordProcessor类属于com.amazonaws.services.kinesis.clientlibrary.interfaces包,在下文中一共展示了IRecordProcessor类的14个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: createProcessor
import com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessor; //导入依赖的package包/类
@Override
public IRecordProcessor createProcessor() {
return new FlumeSourceRecordProcessor(chProcessor,
serializer,
backOffTimeInMillis,
numberRetries,
checkpointIntervalMillis);
}
开发者ID:DevOps-TangoMe,项目名称:flume-kinesis,代码行数:9,代码来源:RecordProcessorFactory.java
示例2: createProcessor
import com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessor; //导入依赖的package包/类
/**
* {@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;
}
}
开发者ID:awslabs,项目名称:aws-kinesis-beanstalk-workers,代码行数:15,代码来源:ManagedClientProcessorFactory.java
示例3: createProcessor
import com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessor; //导入依赖的package包/类
@Override
public IRecordProcessor createProcessor() {
logger.info("Creating RecordProcessor");
if (recordProcessor == null) {
recordProcessor = new RecordProcessor();
}
return recordProcessor;
}
开发者ID:SaschaMoellering,项目名称:ingestion-service,代码行数:9,代码来源:RecordFactory.java
示例4: createProcessor
import com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessor; //导入依赖的package包/类
@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);
}
}
开发者ID:SumoLogic,项目名称:sumologic-kinesis-connector,代码行数:15,代码来源:KinesisConnectorRecordProcessorFactory.java
示例5: createProcessor
import com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessor; //导入依赖的package包/类
/**
* {@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;
}
}
开发者ID:awslabs,项目名称:amazon-kinesis-aggregators,代码行数:15,代码来源:AggregatorProcessorFactory.java
示例6: createProcessor
import com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessor; //导入依赖的package包/类
@Override
public IRecordProcessor createProcessor() {
return new EventRecordProcessor(receiver, workerId,
new KinesisCheckpointState(checkpointInterval));
}
开发者ID:lenards,项目名称:spark-cstar-canaries,代码行数:6,代码来源:EventRecordProcessorFactory.java
示例7: createProcessor
import com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessor; //导入依赖的package包/类
@Override
public IRecordProcessor createProcessor() {
return new KafkaForwardingStreamsRecordProcessor(props, topic);
}
开发者ID:gnethercutt,项目名称:dynamodb-streams-kafka,代码行数:5,代码来源:KafkaForwardingStreamsRecordProcessorFactory.java
示例8: createProcessor
import com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessor; //导入依赖的package包/类
@Override
public IRecordProcessor createProcessor() {
return new Processor();
}
开发者ID:tyagihas,项目名称:awsbigdata,代码行数:5,代码来源:Factory.java
示例9: createProcessor
import com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessor; //导入依赖的package包/类
/**
* {@inheritDoc}
*/
public IRecordProcessor createProcessor() {
return new KinesisRecordProcessor(redisEndpoint, redisPort);
}
开发者ID:awslabs,项目名称:aws-big-data-blog,代码行数:7,代码来源:KinesisRecordProcessorFactory.java
示例10: createProcessor
import com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessor; //导入依赖的package包/类
@Override
public IRecordProcessor createProcessor() {
return new StreamsRecordProcessor(cache);
}
开发者ID:awslabs,项目名称:aws-big-data-blog,代码行数:5,代码来源:StreamsRecordProcessorFactory.java
示例11: createProcessor
import com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessor; //导入依赖的package包/类
@Override
public IRecordProcessor createProcessor() {
return new KinesisRawEventRecordProcessor(this.topic, this.handler, this.mapper);
}
开发者ID:shagwood,项目名称:micro-genie,代码行数:5,代码来源:KinesisRecordProcessorFactory.java
示例12: createProcessor
import com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessor; //导入依赖的package包/类
@Override
public IRecordProcessor createProcessor() {
return new RecordProcessor(_buffer);
}
开发者ID:InformaticaCorp,项目名称:Surf,代码行数:5,代码来源:RecordProcessorFactory.java
示例13: createProcessor
import com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessor; //导入依赖的package包/类
@Override
public IRecordProcessor createProcessor() {
AmazonDynamoDBClient dynamoDBClient = new AmazonDynamoDBClient(dynamoDBCredentials, new ClientConfiguration());
dynamoDBClient.setEndpoint(dynamoDBEndpoint);
return new StreamsRecordProcessor(dynamoDBClient, tableName);
}
开发者ID:awslabs,项目名称:aws-dynamodb-examples,代码行数:7,代码来源:StreamsRecordProcessorFactory.java
示例14: createProcessor
import com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessor; //导入依赖的package包/类
/**
* {@inheritDoc}
*/
@Override
public IRecordProcessor createProcessor() {
return new TweetamoRecordProcessor();
}
开发者ID:dselman,项目名称:tweetamo,代码行数:8,代码来源:TweetamoRecordProcessorFactory.java
注:本文中的com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessor类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论