• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Java UserRecordFailedException类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中com.amazonaws.services.kinesis.producer.UserRecordFailedException的典型用法代码示例。如果您正苦于以下问题:Java UserRecordFailedException类的具体用法?Java UserRecordFailedException怎么用?Java UserRecordFailedException使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



UserRecordFailedException类属于com.amazonaws.services.kinesis.producer包,在下文中一共展示了UserRecordFailedException类的5个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: checkAndPropagateAsyncError

import com.amazonaws.services.kinesis.producer.UserRecordFailedException; //导入依赖的package包/类
/**
 * Check if there are any asynchronous exceptions. If so, rethrow the exception.
 */
private void checkAndPropagateAsyncError() throws Exception {
	if (thrownException != null) {
		String errorMessages = "";
		if (thrownException instanceof UserRecordFailedException) {
			List<Attempt> attempts = ((UserRecordFailedException) thrownException).getResult().getAttempts();
			for (Attempt attempt: attempts) {
				if (attempt.getErrorMessage() != null) {
					errorMessages += attempt.getErrorMessage() + "\n";
				}
			}
		}
		if (failOnError) {
			throw new RuntimeException("An exception was thrown while processing a record: " + errorMessages, thrownException);
		} else {
			LOG.warn("An exception was thrown while processing a record: {}", thrownException, errorMessages);

			// reset, prevent double throwing
			thrownException = null;
		}
	}
}
 
开发者ID:axbaretto,项目名称:flink,代码行数:25,代码来源:FlinkKinesisProducer.java


示例2: send

import com.amazonaws.services.kinesis.producer.UserRecordFailedException; //导入依赖的package包/类
public void send(String event) throws UnsupportedEncodingException {
    byte[] bytes = event.getBytes("UTF-8");
    this.metrics.queueEvent(bytes.length);
    ByteBuffer data = ByteBuffer.wrap(bytes);
    String partitionKey = getPartitionKey(event);
    if (partitionKey != null) {
        ListenableFuture<UserRecordResult> f = producer.addUserRecord(streamName, partitionKey, data);
        Futures.addCallback(f, new FutureCallback<UserRecordResult>() {
            @Override
            public void onFailure(Throwable t) {
                if (t instanceof UserRecordFailedException) {
                    Attempt last = Iterables.getLast(((UserRecordFailedException) t).getResult().getAttempts());
                    LOGGER.error(String.format("Record failed to put - %s : %s", last.getErrorCode(), last.getErrorMessage()));
                }
                LOGGER.error("Exception during put", t);
            }

            @Override
            public void onSuccess(UserRecordResult result) {
                metrics.ackEvent();
            }
        });
    }
}
 
开发者ID:monetate,项目名称:koupler,代码行数:25,代码来源:KinesisEventProducer.java


示例3: onFailure

import com.amazonaws.services.kinesis.producer.UserRecordFailedException; //导入依赖的package包/类
@Override
public void onFailure(Throwable t) {
	if (t instanceof UserRecordFailedException) {
		Attempt last = Iterables.getLast(((UserRecordFailedException) t).getResult().getAttempts());
		throw new DataException("Kinesis Producer was not able to publish data - " + last.getErrorCode() + "-"
				+ last.getErrorMessage());

	}
	throw new DataException("Exception during Kinesis put", t);
}
 
开发者ID:awslabs,项目名称:kinesis-kafka-connector,代码行数:11,代码来源:AmazonKinesisSinkTask.java


示例4: onFailure

import com.amazonaws.services.kinesis.producer.UserRecordFailedException; //导入依赖的package包/类
@Override
public void onFailure(Throwable t) {
    if (t instanceof UserRecordFailedException ){
        Attempt last = Iterables.getLast(
                ((UserRecordFailedException) t).getResult().getAttempts());
        log.error(format(
                "Record failed to put - %s : %s",
                last.getErrorCode(), last.getErrorMessage()));
    }
    log.error("Exception during put", t);
}
 
开发者ID:capside,项目名称:aws-kinesis-zombies,代码行数:12,代码来源:Drone.java


示例5: invoke

import com.amazonaws.services.kinesis.producer.UserRecordFailedException; //导入依赖的package包/类
@Override
public void invoke(OUT value) throws Exception {
	if (this.producer == null) {
		throw new RuntimeException("Kinesis producer has been closed");
	}
	if (thrownException != null) {
		String errorMessages = "";
		if (thrownException instanceof UserRecordFailedException) {
			List<Attempt> attempts = ((UserRecordFailedException) thrownException).getResult().getAttempts();
			for (Attempt attempt: attempts) {
				if (attempt.getErrorMessage() != null) {
					errorMessages += attempt.getErrorMessage() +"\n";
				}
			}
		}
		if (failOnError) {
			throw new RuntimeException("An exception was thrown while processing a record: " + errorMessages, thrownException);
		} else {
			LOG.warn("An exception was thrown while processing a record: {}", thrownException, errorMessages);
			thrownException = null; // reset
		}
	}

	String stream = defaultStream;
	String partition = defaultPartition;

	ByteBuffer serialized = schema.serialize(value);

	// maybe set custom stream
	String customStream = schema.getTargetStream(value);
	if (customStream != null) {
		stream = customStream;
	}

	String explicitHashkey = null;
	// maybe set custom partition
	if (customPartitioner != null) {
		partition = customPartitioner.getPartitionId(value);
		explicitHashkey = customPartitioner.getExplicitHashKey(value);
	}

	if (stream == null) {
		if (failOnError) {
			throw new RuntimeException("No target stream set");
		} else {
			LOG.warn("No target stream set. Skipping record");
			return;
		}
	}

	ListenableFuture<UserRecordResult> cb = producer.addUserRecord(stream, partition, explicitHashkey, serialized);
	Futures.addCallback(cb, callback);
}
 
开发者ID:axbaretto,项目名称:flink,代码行数:54,代码来源:FlinkKinesisProducer.java



注:本文中的com.amazonaws.services.kinesis.producer.UserRecordFailedException类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java OperaOptions类代码示例发布时间:2022-05-22
下一篇:
Java TextDecoration类代码示例发布时间:2022-05-22
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap