com.amazonaws.services.kinesis.model.DescribeStreamRequest.()方法的使用及代码示例

本文整理了Java中com.amazonaws.services.kinesis.model.DescribeStreamRequest.()方法的一些代码示例，展示了DescribeStreamRequest.()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。DescribeStreamRequest.()方法的具体详情如下：
包路径：com.amazonaws.services.kinesis.model.DescribeStreamRequest
类名称：DescribeStreamRequest
方法名：

DescribeStreamRequest.介绍

暂无

代码示例

代码示例来源：origin: aws/aws-sdk-java

/**
* Simplified method form for invoking the DescribeStream operation.
*
* @see #describeStreamAsync(DescribeStreamRequest)
*/
@Override
public java.util.concurrent.Future describeStreamAsync(String streamName) {
return describeStreamAsync(new DescribeStreamRequest().withStreamName(streamName));
}

代码示例来源：origin: aws/aws-sdk-java

/**
* Simplified method form for invoking the DescribeStream operation with an AsyncHandler.
*
* @see #describeStreamAsync(DescribeStreamRequest, com.amazonaws.handlers.AsyncHandler)
*/
@Override
public java.util.concurrent.Future describeStreamAsync(String streamName,
com.amazonaws.handlers.AsyncHandler asyncHandler) {
return describeStreamAsync(new DescribeStreamRequest().withStreamName(streamName), asyncHandler);
}

代码示例来源：origin: aws/aws-sdk-java

/**
* Simplified method form for invoking the DescribeStream operation with an AsyncHandler.
*
* @see #describeStreamAsync(DescribeStreamRequest, com.amazonaws.handlers.AsyncHandler)
*/
@Override
public java.util.concurrent.Future describeStreamAsync(String streamName,
com.amazonaws.handlers.AsyncHandler asyncHandler) {
return describeStreamAsync(new DescribeStreamRequest().withStreamName(streamName), asyncHandler);
}

代码示例来源：origin: aws/aws-sdk-java

/**
* Simplified method form for invoking the DescribeStream operation.
*
* @see #describeStreamAsync(DescribeStreamRequest)
*/
@Override
public java.util.concurrent.Future describeStreamAsync(String streamName) {
return describeStreamAsync(new DescribeStreamRequest().withStreamName(streamName));
}

代码示例来源：origin: aws/aws-sdk-java

@Override
public DescribeStreamResult describeStream(String streamName) {
return describeStream(new DescribeStreamRequest().withStreamName(streamName));
}

代码示例来源：origin: aws/aws-sdk-java

@Override
public DescribeStreamResult describeStream(String streamName) {
return describeStream(new DescribeStreamRequest().withStreamName(streamName));
}

代码示例来源：origin: apache/storm

List getShardsForStream (String stream) {
DescribeStreamRequest describeStreamRequest = new DescribeStreamRequest();
describeStreamRequest.setStreamName(stream);
List shards = new ArrayList<>();
String exclusiveStartShardId = null;
do {
describeStreamRequest.setExclusiveStartShardId(exclusiveStartShardId);
DescribeStreamResult describeStreamResult = kinesisClient.describeStream(describeStreamRequest);
shards.addAll(describeStreamResult.getStreamDescription().getShards());
if (describeStreamResult.getStreamDescription().getHasMoreShards() && shards.size() > 0) {
exclusiveStartShardId = shards.get(shards.size() - 1).getShardId();
} else {
exclusiveStartShardId = null;
}
} while ( exclusiveStartShardId != null );
LOG.info("Number of shards for stream " + stream + " are " + shards.size());
return shards;
}

代码示例来源：origin: aws/aws-sdk-java

/**
* Simplified method form for invoking the DescribeStream operation with an AsyncHandler.
*
* @see #describeStreamAsync(DescribeStreamRequest, com.amazonaws.handlers.AsyncHandler)
*/
@Override
public java.util.concurrent.Future describeStreamAsync(String streamName, String exclusiveStartShardId,
com.amazonaws.handlers.AsyncHandler asyncHandler) {
return describeStreamAsync(new DescribeStreamRequest().withStreamName(streamName).withExclusiveStartShardId(exclusiveStartShardId), asyncHandler);
}

代码示例来源：origin: aws/aws-sdk-java

/**
* Simplified method form for invoking the DescribeStream operation.
*
* @see #describeStreamAsync(DescribeStreamRequest)
*/
@Override
public java.util.concurrent.Future describeStreamAsync(String streamName, String exclusiveStartShardId) {
return describeStreamAsync(new DescribeStreamRequest().withStreamName(streamName).withExclusiveStartShardId(exclusiveStartShardId));
}

代码示例来源：origin: aws/aws-sdk-java

/**
* Simplified method form for invoking the DescribeStream operation with an AsyncHandler.
*
* @see #describeStreamAsync(DescribeStreamRequest, com.amazonaws.handlers.AsyncHandler)
*/
@Override
public java.util.concurrent.Future describeStreamAsync(String streamName, String exclusiveStartShardId,
com.amazonaws.handlers.AsyncHandler asyncHandler) {
return describeStreamAsync(new DescribeStreamRequest().withStreamName(streamName).withExclusiveStartShardId(exclusiveStartShardId), asyncHandler);
}

代码示例来源：origin: aws/aws-sdk-java

/**
* Simplified method form for invoking the DescribeStream operation.
*
* @see #describeStreamAsync(DescribeStreamRequest)
*/
@Override
public java.util.concurrent.Future describeStreamAsync(String streamName, String exclusiveStartShardId) {
return describeStreamAsync(new DescribeStreamRequest().withStreamName(streamName).withExclusiveStartShardId(exclusiveStartShardId));
}

代码示例来源：origin: aws/aws-sdk-java

@Override
public DescribeStreamResult describeStream(String streamName, String exclusiveStartShardId) {
return describeStream(new DescribeStreamRequest().withStreamName(streamName).withExclusiveStartShardId(exclusiveStartShardId));
}

代码示例来源：origin: aws/aws-sdk-java

@Override
public DescribeStreamResult describeStream(String streamName, String exclusiveStartShardId) {
return describeStream(new DescribeStreamRequest().withStreamName(streamName).withExclusiveStartShardId(exclusiveStartShardId));
}

代码示例来源：origin: aws/aws-sdk-java

/**
* Simplified method form for invoking the DescribeStream operation.
*
* @see #describeStreamAsync(DescribeStreamRequest)
*/
@Override
public java.util.concurrent.Future describeStreamAsync(String streamName, Integer limit, String exclusiveStartShardId) {
return describeStreamAsync(new DescribeStreamRequest().withStreamName(streamName).withLimit(limit).withExclusiveStartShardId(exclusiveStartShardId));
}

代码示例来源：origin: aws/aws-sdk-java

/**
* Simplified method form for invoking the DescribeStream operation.
*
* @see #describeStreamAsync(DescribeStreamRequest)
*/
@Override
public java.util.concurrent.Future describeStreamAsync(String streamName, Integer limit, String exclusiveStartShardId) {
return describeStreamAsync(new DescribeStreamRequest().withStreamName(streamName).withLimit(limit).withExclusiveStartShardId(exclusiveStartShardId));
}

代码示例来源：origin: aws/aws-sdk-java

/**
* Simplified method form for invoking the DescribeStream operation with an AsyncHandler.
*
* @see #describeStreamAsync(DescribeStreamRequest, com.amazonaws.handlers.AsyncHandler)
*/
@Override
public java.util.concurrent.Future describeStreamAsync(String streamName, Integer limit, String exclusiveStartShardId,
com.amazonaws.handlers.AsyncHandler asyncHandler) {
return describeStreamAsync(new DescribeStreamRequest().withStreamName(streamName).withLimit(limit).withExclusiveStartShardId(exclusiveStartShardId),
asyncHandler);
}

代码示例来源：origin: aws/aws-sdk-java

/**
* Simplified method form for invoking the DescribeStream operation with an AsyncHandler.
*
* @see #describeStreamAsync(DescribeStreamRequest, com.amazonaws.handlers.AsyncHandler)
*/
@Override
public java.util.concurrent.Future describeStreamAsync(String streamName, Integer limit, String exclusiveStartShardId,
com.amazonaws.handlers.AsyncHandler asyncHandler) {
return describeStreamAsync(new DescribeStreamRequest().withStreamName(streamName).withLimit(limit).withExclusiveStartShardId(exclusiveStartShardId),
asyncHandler);
}

代码示例来源：origin: aws/aws-sdk-java

@Override
public DescribeStreamResult describeStream(String streamName, Integer limit, String exclusiveStartShardId) {
return describeStream(new DescribeStreamRequest().withStreamName(streamName).withLimit(limit).withExclusiveStartShardId(exclusiveStartShardId));
}

代码示例来源：origin: aws/aws-sdk-java

@Override
public DescribeStreamResult describeStream(String streamName, Integer limit, String exclusiveStartShardId) {
return describeStream(new DescribeStreamRequest().withStreamName(streamName).withLimit(limit).withExclusiveStartShardId(exclusiveStartShardId));
}

代码示例来源：origin: rakam-io/rakam

/**
* Return the state of a Amazon Kinesis stream.
*
* @param kinesisClient The {@link com.amazonaws.services.kinesis.AmazonKinesisClient} with Amazon Kinesis read privileges
* @param streamName The Amazon Kinesis stream to get the state of
* @return String representation of the Stream state
*/
private static String streamState(AmazonKinesisClient kinesisClient, String streamName) {
DescribeStreamRequest describeStreamRequest = new DescribeStreamRequest();
describeStreamRequest.setStreamName(streamName);
try {
return kinesisClient.describeStream(describeStreamRequest).getStreamDescription().getStreamStatus();
} catch (AmazonServiceException e) {
return null;
}
}