Java ByteArray类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

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

本文整理汇总了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；未经允许，请勿转载。