本文整理了Java中com.amazonaws.services.kinesis.clientlibrary.lib.worker.Worker.<init>()
方法的一些代码示例,展示了Worker.<init>()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Worker.<init>()
方法的具体详情如下:
包路径:com.amazonaws.services.kinesis.clientlibrary.lib.worker.Worker
类名称:Worker
方法名:<init>
[英]Constructor.
[中]建造师。
代码示例来源:origin: harishreedharan/usingflumecode
@Override
public void run() {
while (!Thread.currentThread().isInterrupted()){
worker = new Worker(processorFactory, clientConfig);
worker.run(); // Returns when worker is shutdown
}
}
});
代码示例来源:origin: awslabs/amazon-kinesis-aggregators
public int run() throws Exception {
configure();
System.out.println(String.format("Starting %s", appName));
LOG.info(String.format("Running %s to process stream %s", appName,
streamName));
IRecordProcessorFactory recordProcessorFactory = new AggregatorProcessorFactory(
aggGroup);
worker = new Worker(recordProcessorFactory, this.config);
int exitCode = 0;
int failures = 0;
// run the worker, tolerating as many failures as is configured
while (failures < failuresToTolerate || failuresToTolerate == -1) {
try {
worker.run();
} catch (Throwable t) {
LOG.error("Caught throwable while processing data.", t);
failures++;
if (failures < failuresToTolerate) {
LOG.error("Restarting...");
} else {
shutdown();
}
exitCode = 1;
}
}
return exitCode;
}
代码示例来源:origin: aws/amazon-kinesis-video-streams-parser-library
@Override
public void run() {
try {
String workerId = InetAddress.getLocalHost().getCanonicalHostName() + ":" + UUID.randomUUID();
KinesisClientLibConfiguration kinesisClientLibConfiguration = new KinesisClientLibConfiguration(APPLICATION_NAME, kdsStreamName, credentialsProvider, workerId);
kinesisClientLibConfiguration.withInitialPositionInStream(SAMPLE_APPLICATION_INITIAL_POSITION_IN_STREAM).withRegionName(region.getName());
final IRecordProcessorFactory recordProcessorFactory = () -> new KinesisRecordProcessor(rekognizedFragmentsIndex, credentialsProvider);
final Worker worker = new Worker(recordProcessorFactory, kinesisClientLibConfiguration);
System.out.printf("Running %s to process stream %s as worker %s...", APPLICATION_NAME, kdsStreamName, workerId);
int exitCode = 0;
try {
worker.run();
} catch (Throwable t) {
System.err.println("Caught throwable while processing data.");
t.printStackTrace();
exitCode = 1;
}
System.out.println("Exit code : " + exitCode);
} catch (Exception e) {
e.printStackTrace();
}
}
代码示例来源:origin: aws-samples/aws-dynamodb-examples
worker = new Worker(recordProcessorFactory, workerConfig, adapterClient, dynamoDBClient, cloudWatchClient);
System.out.println("Starting worker...");
Thread t = new Thread(worker);
代码示例来源:origin: awslabs/amazon-kinesis-connectors
new Worker(getKinesisConnectorRecordProcessorFactory(),
kinesisClientLibConfiguration,
metricFactory);
} else {
worker = new Worker(getKinesisConnectorRecordProcessorFactory(), kinesisClientLibConfiguration);
代码示例来源:origin: com.amazonaws/amazon-kinesis-connectors
new Worker(getKinesisConnectorRecordProcessorFactory(),
kinesisClientLibConfiguration,
metricFactory);
} else {
worker = new Worker(getKinesisConnectorRecordProcessorFactory(), kinesisClientLibConfiguration);
代码示例来源:origin: awslabs/dynamodb-cross-region-library
return new Worker(factory, kclConfig, streamsAdapterClient, kclDynamoDBClient, kclCloudWatchClient);
代码示例来源:origin: com.amazonaws/amazon-kinesis-client
return new Worker(config.getApplicationName(),
recordProcessorFactory,
config,
内容来源于网络,如有侵权,请联系作者删除!