本文整理汇总了Java中com.google.cloud.ByteArray类的典型用法代码示例。如果您正苦于以下问题:Java ByteArray类的具体用法?Java ByteArray怎么用?Java ByteArray使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
ByteArray类属于com.google.cloud包,在下文中一共展示了ByteArray类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: sizeOf
import com.google.cloud.ByteArray; //导入依赖的package包/类
private static long sizeOf(Key k) {
long result = 0;
for (Object part : k.getParts()) {
if (part == null) {
continue;
}
if (part instanceof Boolean) {
result += 1;
} else if (part instanceof Long) {
result += 8;
} else if (part instanceof Double) {
result += 8;
} else if (part instanceof String) {
result += ((String) part).length();
} else if (part instanceof ByteArray) {
result += ((ByteArray) part).length();
} else if (part instanceof Timestamp) {
result += 12;
} else if (part instanceof Date) {
result += 12;
}
}
return result;
}
开发者ID:apache,项目名称:beam,代码行数:25,代码来源:MutationSizeEstimator.java
示例2: bytes
import com.google.cloud.ByteArray; //导入依赖的package包/类
@Test
public void bytes() throws Exception {
Mutation empty =
Mutation.newInsertOrUpdateBuilder("test").set("one").to(ByteArray.fromBase64("")).build();
Mutation nullValue =
Mutation.newInsertOrUpdateBuilder("test").set("one").to((ByteArray) null).build();
Mutation sample =
Mutation.newInsertOrUpdateBuilder("test")
.set("one")
.to(ByteArray.fromBase64("abcdabcd"))
.build();
assertThat(MutationSizeEstimator.sizeOf(empty), is(0L));
assertThat(MutationSizeEstimator.sizeOf(nullValue), is(0L));
assertThat(MutationSizeEstimator.sizeOf(sample), is(6L));
}
开发者ID:apache,项目名称:beam,代码行数:17,代码来源:MutationSizeEstimatorTest.java
示例3: testDeletes
import com.google.cloud.ByteArray; //导入依赖的package包/类
@Test
public void testDeletes() throws Exception {
encodeAndVerify(g(Mutation.delete("test", Key.of(1L))));
encodeAndVerify(g(Mutation.delete("test", Key.of((Long) null))));
KeySet allTypes = KeySet.newBuilder()
.addKey(Key.of(1L))
.addKey(Key.of((Long) null))
.addKey(Key.of(1.2))
.addKey(Key.of((Double) null))
.addKey(Key.of("one"))
.addKey(Key.of((String) null))
.addKey(Key.of(ByteArray.fromBase64("abcd")))
.addKey(Key.of((ByteArray) null))
.addKey(Key.of(Timestamp.now()))
.addKey(Key.of((Timestamp) null))
.addKey(Key.of(Date.fromYearMonthDay(2012, 1, 1)))
.addKey(Key.of((Date) null))
.build();
encodeAndVerify(g(Mutation.delete("test", allTypes)));
encodeAndVerify(
g(Mutation
.delete("test", KeySet.range(KeyRange.closedClosed(Key.of(1L), Key.of(2L))))));
}
开发者ID:apache,项目名称:beam,代码行数:27,代码来源:MutationGroupEncoderTest.java
示例4: toCloudSpannerBytes
import com.google.cloud.ByteArray; //导入依赖的package包/类
public static List<ByteArray> toCloudSpannerBytes(byte[][] bytes)
{
List<ByteArray> res = new ArrayList<>(bytes.length);
for (int index = 0; index < bytes.length; index++)
res.add(ByteArray.copyFrom(bytes[index]));
return res;
}
开发者ID:olavloite,项目名称:spanner-jdbc,代码行数:8,代码来源:CloudSpannerConversionUtil.java
示例5: toJavaByteArrays
import com.google.cloud.ByteArray; //导入依赖的package包/类
public static List<byte[]> toJavaByteArrays(List<ByteArray> bytes)
{
List<byte[]> res = new ArrayList<>(bytes.size());
for (ByteArray ba : bytes)
res.add(ba.toByteArray());
return res;
}
开发者ID:olavloite,项目名称:spanner-jdbc,代码行数:8,代码来源:CloudSpannerConversionUtil.java
示例6: testGetBytesIndex
import com.google.cloud.ByteArray; //导入依赖的package包/类
@Test
public void testGetBytesIndex() throws SQLException
{
assertNotNull(subject.getBytes(BYTES_COLINDEX_NOTNULL));
assertArrayEquals(ByteArray.copyFrom("BAR").toByteArray(), subject.getBytes(BYTES_COLINDEX_NOTNULL));
assertEquals(false, subject.wasNull());
assertNull(subject.getBytes(BYTES_COLINDEX_NULL));
assertTrue(subject.wasNull());
}
开发者ID:olavloite,项目名称:spanner-jdbc,代码行数:10,代码来源:CloudSpannerResultSetTest.java
示例7: testGetBytesLabel
import com.google.cloud.ByteArray; //导入依赖的package包/类
@Test
public void testGetBytesLabel() throws SQLException
{
assertNotNull(subject.getBytes(BYTES_COL_NOT_NULL));
assertArrayEquals(ByteArray.copyFrom("FOO").toByteArray(), subject.getBytes(BYTES_COL_NOT_NULL));
assertEquals(false, subject.wasNull());
assertNull(subject.getBytes(BYTES_COL_NULL));
assertTrue(subject.wasNull());
}
开发者ID:olavloite,项目名称:spanner-jdbc,代码行数:10,代码来源:CloudSpannerResultSetTest.java
示例8: testGetBinaryStreamIndex
import com.google.cloud.ByteArray; //导入依赖的package包/类
@Test
public void testGetBinaryStreamIndex() throws SQLException, IOException
{
assertNotNull(subject.getBinaryStream(BYTES_COLINDEX_NOTNULL));
InputStream actual = subject.getBinaryStream(BYTES_COLINDEX_NOTNULL);
byte[] cbuf = new byte[3];
int len = actual.read(cbuf, 0, cbuf.length);
assertArrayEquals(ByteArray.copyFrom("BAR").toByteArray(), cbuf);
assertEquals(3, len);
assertEquals(false, subject.wasNull());
assertNull(subject.getUnicodeStream(BYTES_COLINDEX_NULL));
assertTrue(subject.wasNull());
}
开发者ID:olavloite,项目名称:spanner-jdbc,代码行数:14,代码来源:CloudSpannerResultSetTest.java
示例9: testGetBinaryStreamLabel
import com.google.cloud.ByteArray; //导入依赖的package包/类
@Test
public void testGetBinaryStreamLabel() throws SQLException, IOException
{
assertNotNull(subject.getBinaryStream(BYTES_COL_NOT_NULL));
InputStream actual = subject.getBinaryStream(BYTES_COL_NOT_NULL);
byte[] cbuf = new byte[3];
int len = actual.read(cbuf, 0, cbuf.length);
assertArrayEquals(ByteArray.copyFrom("FOO").toByteArray(), cbuf);
assertEquals(3, len);
assertEquals(false, subject.wasNull());
assertNull(subject.getUnicodeStream(BYTES_COL_NULL));
assertTrue(subject.wasNull());
}
开发者ID:olavloite,项目名称:spanner-jdbc,代码行数:14,代码来源:CloudSpannerResultSetTest.java
示例10: assertSingleInsert
import com.google.cloud.ByteArray; //导入依赖的package包/类
private void assertSingleInsert(Mutation mutation, Mutation.Op operation)
{
Assert.assertNotNull(mutation);
Assert.assertEquals(operation, mutation.getOperation());
Assert.assertEquals("FOO", mutation.getTable());
List<String> columns = Lists.newArrayList(mutation.getColumns());
Assert.assertArrayEquals(new String[] { "COL1", "COL2", "COL3" }, columns.toArray());
Assert.assertArrayEquals(
new String[] { "1", "two", ByteArray.copyFrom(DatatypeConverter.parseHexBinary("aa")).toString() },
getValues(mutation.getValues()));
}
开发者ID:olavloite,项目名称:spanner-jdbc,代码行数:12,代码来源:CloudSpannerPreparedStatementTest.java
示例11: testToCloudSpannerBytes
import com.google.cloud.ByteArray; //导入依赖的package包/类
@Test
public void testToCloudSpannerBytes()
{
byte[][] input = new byte[][] { "AA".getBytes(), "BB".getBytes() };
List<ByteArray> output = CloudSpannerConversionUtil.toCloudSpannerBytes(input);
ByteArray inp1 = ByteArray.copyFrom("AA".getBytes());
ByteArray inp2 = ByteArray.copyFrom("BB".getBytes());
assertArrayEquals(new ByteArray[] { inp1, inp2 }, output.toArray());
}
开发者ID:olavloite,项目名称:spanner-jdbc,代码行数:10,代码来源:CloudSpannerConversionUtilTest.java
示例12: testToJavaByteArrays
import com.google.cloud.ByteArray; //导入依赖的package包/类
@Test
public void testToJavaByteArrays()
{
ByteArray inp1 = ByteArray.copyFrom("AA".getBytes());
ByteArray inp2 = ByteArray.copyFrom("BB".getBytes());
List<byte[]> output = CloudSpannerConversionUtil.toJavaByteArrays(Arrays.asList(inp1, inp2));
List<byte[]> list = Arrays.asList("AA".getBytes(), "BB".getBytes());
assertArrayEquals(list.toArray(), output.toArray());
}
开发者ID:olavloite,项目名称:spanner-jdbc,代码行数:11,代码来源:CloudSpannerConversionUtilTest.java
示例13: convert
import com.google.cloud.ByteArray; //导入依赖的package包/类
protected PubSubMessage convert(Message<?> message) throws Exception {
String encodedHeaders = encodeHeaders(message.getHeaders());
String topic = producerProperties.isPartitioned() ? topics
.get((Integer) message.getHeaders().get(BinderHeaders.PARTITION_HEADER))
.name() : topics.get(0).name();
PubSubMessage pubSubMessage = new PubSubMessage(
com.google.cloud.pubsub.Message
.builder(ByteArray.copyFrom((byte[]) message.getPayload()))
.addAttribute(PubSubBinder.SCST_HEADERS, encodedHeaders).build(),
topic);
return pubSubMessage;
}
开发者ID:viniciusccarvalho,项目名称:spring-cloud-stream-binder-pubsub,代码行数:13,代码来源:PubSubMessageHandler.java
示例14: encodePrimitive
import com.google.cloud.ByteArray; //导入依赖的package包/类
private void encodePrimitive(ByteArrayOutputStream bos, Value value) throws IOException {
switch (value.getType().getCode()) {
case BOOL:
bos.write(value.getBool() ? 1 : 0);
break;
case INT64:
VarInt.encode(value.getInt64(), bos);
break;
case FLOAT64:
new DataOutputStream(bos).writeDouble(value.getFloat64());
break;
case STRING: {
String str = value.getString();
VarInt.encode(str.length(), bos);
bos.write(str.getBytes(StandardCharsets.UTF_8));
break;
}
case BYTES: {
ByteArray bytes = value.getBytes();
VarInt.encode(bytes.length(), bos);
bos.write(bytes.toByteArray());
break;
}
case TIMESTAMP: {
Timestamp timestamp = value.getTimestamp();
VarInt.encode(timestamp.getSeconds(), bos);
VarInt.encode(timestamp.getNanos(), bos);
break;
}
case DATE: {
Date date = value.getDate();
VarInt.encode(encodeDate(date), bos);
break;
}
default:
throw new IllegalArgumentException("Unknown type " + value.getType());
}
}
开发者ID:apache,项目名称:beam,代码行数:39,代码来源:MutationGroupEncoder.java
示例15: estimateArrayValue
import com.google.cloud.ByteArray; //导入依赖的package包/类
private static long estimateArrayValue(Value v) {
switch (v.getType().getArrayElementType().getCode()) {
case BOOL:
return v.getBoolArray().size();
case INT64:
return 8 * v.getInt64Array().size();
case FLOAT64:
return 8 * v.getFloat64Array().size();
case STRING:
long totalLength = 0;
for (String s : v.getStringArray()) {
if (s == null) {
continue;
}
totalLength += s.length();
}
return totalLength;
case BYTES:
totalLength = 0;
for (ByteArray bytes : v.getBytesArray()) {
if (bytes == null) {
continue;
}
totalLength += bytes.length();
}
return totalLength;
case DATE:
return 12 * v.getDateArray().size();
case TIMESTAMP:
return 12 * v.getTimestampArray().size();
}
throw new IllegalArgumentException("Unsupported type " + v.getType());
}
开发者ID:apache,项目名称:beam,代码行数:34,代码来源:MutationSizeEstimator.java
示例16: appendAllTypes
import com.google.cloud.ByteArray; //导入依赖的package包/类
private Mutation.WriteBuilder appendAllTypes(Mutation.WriteBuilder builder) {
Timestamp ts = Timestamp.now();
Date date = Date.fromYearMonthDay(2017, 1, 1);
return builder
.set("bool").to(true)
.set("int64").to(1L)
.set("float64").to(1.0)
.set("string").to("my string")
.set("bytes").to(ByteArray.fromBase64("abcdedf"))
.set("timestamp").to(ts)
.set("date").to(date)
.set("arrbool").toBoolArray(Arrays.asList(true, false, null, true, null, false))
.set("arrint64").toInt64Array(Arrays.asList(10L, -12L, null, null, 100000L))
.set("arrfloat64").toFloat64Array(Arrays.asList(10., -12.23, null, null, 100000.33231))
.set("arrstring").toStringArray(Arrays.asList("one", "two", null, null, "three"))
.set("arrbytes").toBytesArray(Arrays.asList(ByteArray.fromBase64("abcs"), null))
.set("arrtimestamp").toTimestampArray(Arrays.asList(Timestamp.MIN_VALUE, null, ts))
.set("arrdate").toDateArray(Arrays.asList(null, date))
.set("nullbool").to((Boolean) null)
.set("nullint64").to((Long) null)
.set("nullfloat64").to((Double) null)
.set("nullstring").to((String) null)
.set("nullbytes").to((ByteArray) null)
.set("nulltimestamp").to((Timestamp) null)
.set("nulldate").to((Date) null)
.set("nullarrbool").toBoolArray((Iterable<Boolean>) null)
.set("nullarrint64").toInt64Array((Iterable<Long>) null)
.set("nullarrfloat64").toFloat64Array((Iterable<Double>) null)
.set("nullarrstring").toStringArray(null)
.set("nullarrbytes").toBytesArray(null)
.set("nullarrtimestamp").toTimestampArray(null)
.set("nullarrdate").toDateArray(null);
}
开发者ID:apache,项目名称:beam,代码行数:37,代码来源:MutationGroupEncoderTest.java
示例17: bytesKeys
import com.google.cloud.ByteArray; //导入依赖的package包/类
@Test
public void bytesKeys() throws Exception {
SpannerSchema.Builder builder = SpannerSchema.builder();
builder.addColumn("test", "key", "BYTES");
builder.addKeyPart("test", "key", false);
builder.addColumn("test", "keydesc", "BYTES");
builder.addKeyPart("test", "keydesc", true);
SpannerSchema schema = builder.build();
List<Mutation> mutations = Arrays.asList(
Mutation.newInsertOrUpdateBuilder("test")
.set("key").to(ByteArray.fromBase64("abc"))
.set("keydesc").to(ByteArray.fromBase64("zzz"))
.build(),
Mutation.newInsertOrUpdateBuilder("test")
.set("key").to(ByteArray.fromBase64("xxx"))
.set("keydesc").to((ByteArray) null)
.build(),
Mutation.newInsertOrUpdateBuilder("test")
.set("key").to(ByteArray.fromBase64("xxx"))
.set("keydesc").to(ByteArray.fromBase64("zzzz"))
.build(),
Mutation.newInsertOrUpdateBuilder("test")
.set("key").to(ByteArray.fromBase64("xxx"))
.set("keydesc").to(ByteArray.fromBase64("ssss"))
.build(),
Mutation.newInsertOrUpdateBuilder("test")
.set("key").to(ByteArray.fromBase64("xxx"))
.set("keydesc").to(ByteArray.fromBase64("aaa"))
.build());
List<Key> keys = Arrays.asList(
Key.of(ByteArray.fromBase64("abc"), ByteArray.fromBase64("zzz")),
Key.of(ByteArray.fromBase64("xxx"), null),
Key.of(ByteArray.fromBase64("xxx"), ByteArray.fromBase64("zzz")),
Key.of(ByteArray.fromBase64("xxx"), ByteArray.fromBase64("sss")),
Key.of(ByteArray.fromBase64("xxx"), ByteArray.fromBase64("aaa"))
);
verifyEncodedOrdering(schema, mutations);
verifyEncodedOrdering(schema, "test", keys);
}
开发者ID:apache,项目名称:beam,代码行数:46,代码来源:MutationGroupEncoderTest.java
示例18: dateKeys
import com.google.cloud.ByteArray; //导入依赖的package包/类
@Test
public void dateKeys() throws Exception {
SpannerSchema.Builder builder = SpannerSchema.builder();
builder.addColumn("test", "key", "DATE");
builder.addKeyPart("test", "key", false);
builder.addColumn("test", "keydesc", "DATE");
builder.addKeyPart("test", "keydesc", true);
SpannerSchema schema = builder.build();
List<Mutation> mutations = Arrays.asList(
Mutation.newInsertOrUpdateBuilder("test")
.set("key").to(Date.fromYearMonthDay(2012, 10, 10))
.set("keydesc").to(Date.fromYearMonthDay(2000, 10, 10))
.build(),
Mutation.newInsertOrUpdateBuilder("test")
.set("key").to(Date.fromYearMonthDay(2020, 10, 10))
.set("keydesc").to((Date) null)
.build(),
Mutation.newInsertOrUpdateBuilder("test")
.set("key").to(Date.fromYearMonthDay(2020, 10, 10))
.set("keydesc").to(Date.fromYearMonthDay(2050, 10, 10))
.build(),
Mutation.newInsertOrUpdateBuilder("test")
.set("key").to(Date.fromYearMonthDay(2020, 10, 10))
.set("keydesc").to(Date.fromYearMonthDay(2000, 10, 10))
.build(),
Mutation.newInsertOrUpdateBuilder("test")
.set("key").to(Date.fromYearMonthDay(2020, 10, 10))
.set("keydesc").to(Date.fromYearMonthDay(1900, 10, 10))
.build());
List<Key> keys = Arrays.asList(
Key.of(Date.fromYearMonthDay(2012, 10, 10), ByteArray.fromBase64("zzz")),
Key.of(Date.fromYearMonthDay(2015, 10, 10), null),
Key.of(Date.fromYearMonthDay(2015, 10, 10), Date.fromYearMonthDay(2050, 10, 10)),
Key.of(Date.fromYearMonthDay(2015, 10, 10), Date.fromYearMonthDay(2000, 10, 10)),
Key.of(Date.fromYearMonthDay(2015, 10, 10), Date.fromYearMonthDay(1900, 10, 10))
);
verifyEncodedOrdering(schema, mutations);
verifyEncodedOrdering(schema, "test", keys);
}
开发者ID:apache,项目名称:beam,代码行数:46,代码来源:MutationGroupEncoderTest.java
示例19: timestampKeys
import com.google.cloud.ByteArray; //导入依赖的package包/类
@Test
public void timestampKeys() throws Exception {
SpannerSchema.Builder builder = SpannerSchema.builder();
builder.addColumn("test", "key", "TIMESTAMP");
builder.addKeyPart("test", "key", false);
builder.addColumn("test", "keydesc", "TIMESTAMP");
builder.addKeyPart("test", "keydesc", true);
SpannerSchema schema = builder.build();
List<Mutation> mutations = Arrays.asList(
Mutation.newInsertOrUpdateBuilder("test")
.set("key").to(Timestamp.ofTimeMicroseconds(10000))
.set("keydesc").to(Timestamp.ofTimeMicroseconds(50000))
.build(),
Mutation.newInsertOrUpdateBuilder("test")
.set("key").to(Timestamp.ofTimeMicroseconds(20000))
.set("keydesc").to((Timestamp) null)
.build(),
Mutation.newInsertOrUpdateBuilder("test")
.set("key").to(Timestamp.ofTimeMicroseconds(20000))
.set("keydesc").to(Timestamp.ofTimeMicroseconds(90000))
.build(),
Mutation.newInsertOrUpdateBuilder("test")
.set("key").to(Timestamp.ofTimeMicroseconds(20000))
.set("keydesc").to(Timestamp.ofTimeMicroseconds(50000))
.build(),
Mutation.newInsertOrUpdateBuilder("test")
.set("key").to(Timestamp.ofTimeMicroseconds(20000))
.set("keydesc").to(Timestamp.ofTimeMicroseconds(10000))
.build());
List<Key> keys = Arrays.asList(
Key.of(Timestamp.ofTimeMicroseconds(10000), ByteArray.fromBase64("zzz")),
Key.of(Timestamp.ofTimeMicroseconds(20000), null),
Key.of(Timestamp.ofTimeMicroseconds(20000), Timestamp.ofTimeMicroseconds(90000)),
Key.of(Timestamp.ofTimeMicroseconds(20000), Timestamp.ofTimeMicroseconds(50000)),
Key.of(Timestamp.ofTimeMicroseconds(20000), Timestamp.ofTimeMicroseconds(10000))
);
verifyEncodedOrdering(schema, mutations);
verifyEncodedOrdering(schema, "test", keys);
}
开发者ID:apache,项目名称:beam,代码行数:47,代码来源:MutationGroupEncoderTest.java
示例20: boolKeys
import com.google.cloud.ByteArray; //导入依赖的package包/类
@Test
public void boolKeys() throws Exception {
SpannerSchema.Builder builder = SpannerSchema.builder();
builder.addColumn("test", "boolkey", "BOOL");
builder.addKeyPart("test", "boolkey", false);
builder.addColumn("test", "boolkeydesc", "BOOL");
builder.addKeyPart("test", "boolkeydesc", true);
SpannerSchema schema = builder.build();
List<Mutation> mutations = Arrays.asList(
Mutation.newInsertOrUpdateBuilder("test")
.set("boolkey").to(true)
.set("boolkeydesc").to(false)
.build(),
Mutation.newInsertOrUpdateBuilder("test")
.set("boolkey").to(false)
.set("boolkeydesc").to(false)
.build(),
Mutation.newInsertOrUpdateBuilder("test")
.set("boolkey").to(false)
.set("boolkeydesc").to(true)
.build(),
Mutation.newInsertOrUpdateBuilder("test")
.set("boolkey").to((Boolean) null)
.set("boolkeydesc").to(false)
.build()
);
List<Key> keys = Arrays.asList(
Key.of(true, ByteArray.fromBase64("zzz")),
Key.of(false, null),
Key.of(false, false),
Key.of(false, true),
Key.of(null, false)
);
verifyEncodedOrdering(schema, mutations);
verifyEncodedOrdering(schema, "test", keys);
}
开发者ID:apache,项目名称:beam,代码行数:43,代码来源:MutationGroupEncoderTest.java
注:本文中的com.google.cloud.ByteArray类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论