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

DataByteArray.<init>介绍

[英]Default constructor. The data array will not be allocated when this constructor is called.
[中]默认构造函数。调用此构造函数时，将不会分配数据数组。

代码示例

代码示例来源：origin: elastic/elasticsearch-hadoop

@Override
protected Object binaryValue(byte[] value) {
  return new DataByteArray(value);
}

代码示例来源：origin: elastic/elasticsearch-hadoop

@Test
public void testNamedByteArray() {
  String expected = "{\"name\":\"Ynl0ZSBhcnJheQ==\"}";
  assertThat(pigTypeToJson(createTuple(new DataByteArray("byte array".getBytes()), createSchema("name:bytearray"))), is(expected));
}

代码示例来源：origin: elastic/elasticsearch-hadoop

@Test
public void testAnonByteArray() {
  String expected = "{\"val_0\":\"Ynl0ZSBhcnJheQ==\"}";
  assertThat(pigTypeToJson(createTuple(new DataByteArray("byte array".getBytes()), createSchema("bytearray"))),
      is(expected));
}

代码示例来源：origin: elastic/elasticsearch-hadoop

@Test
public void testByteArray() {
  String expected = "{\"name\":\"Ynl0ZSBhcnJheQ==\"}";
  assertThat(pigTypeToJson(createTuple(new DataByteArray("byte array".getBytes()), createSchema("name:bytearray"))), is(expected));
}

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

switch (itemType) {
case BINARY:
 result = new DataByteArray((byte[]) o);
 break;
case STRUCT:

代码示例来源：origin: org.apache.pig/pig

protected DataByteArray box(byte[] v) {
  if (v == null) {
    return null;
  }
  return new DataByteArray(v);
}

代码示例来源：origin: org.apache.pig/pig

/**
 * This constructor encapsulated a null DataByteArray.
 *
 * @param ruby an instance of the ruby runtime
 * @param rc   an instance of the class object with meatadata
 */
protected RubyDataByteArray(final Ruby ruby, RubyClass rc) {
  super(ruby,rc);
  internalDBA = new DataByteArray();
}

代码示例来源：origin: org.apache.pig/pig

/**
 * This constructor creates a new DataByteArray with a reference to the provided bytes.
 *
 * @param ruby an instance of the ruby runtime
 * @param rc   an instance of the class object with meatadata
 * @param buf  a byte array to encapsulate directly
 */
protected RubyDataByteArray(final Ruby ruby, RubyClass rc, byte[] buf) {
  super(ruby,rc);
  internalDBA = new DataByteArray(buf);
}

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

Tuple t = tupleFactory.newTuple();
t.append(i);
t.append(new DataByteArray(Bytes.toBytes(i * 5)));
t.append(new DataByteArray(Bytes.toBytes(i * 10.0F)));
t.append(new DataByteArray(Bytes.toBytes(i * 15.0D)));
t.append(new DataByteArray(Bytes.toBytes(i)));
t.append(new DataByteArray(Bytes.toBytes( i % 2 == 0)));
t.append(new DataByteArray(Bytes.toBytes(i)));
list.add(t);

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

case DataType.BYTEARRAY:
  byte[] bytes = PDataType.fromTypeId(PBinary.INSTANCE.getSqlType()).toBytes(object);
  tuple.set(i, new DataByteArray(bytes, 0, bytes.length));
  break;
case DataType.CHARARRAY:

代码示例来源：origin: org.apache.pig/pig

private static Object readBytes(DataInput in, int size) throws IOException {
  byte[] ba = new byte[size];
  in.readFully(ba);
  return new DataByteArray(ba);
}

代码示例来源：origin: org.apache.pig/pig

private static void readField(ArrayList<Object> protoTuple,
           byte[] buf, int start, int end) {
  if (start == end) {
    // NULL value
    protoTuple.add(null);
  } else {
    protoTuple.add(new DataByteArray(buf, start, end));
  }
}

代码示例来源：origin: org.apache.pig/pig

protected DataByteArray bloomOut() throws IOException {
  ByteArrayOutputStream baos = new ByteArrayOutputStream(vSize / 8);
  DataOutputStream dos = new DataOutputStream(baos);
  filter.write(dos);
  return new DataByteArray(baos.toByteArray());
}

代码示例来源：origin: org.apache.pig/pig

/**
 * This is the default initializer, which returns an empty DataByteArray.
 *
 * @return the initialized RubyDataByteArray
 */
@JRubyMethod
@SuppressWarnings("deprecation")
public RubyDataByteArray initialize() {
  internalDBA = new DataByteArray();
  return this;
}

代码示例来源：origin: pl.edu.icm.coansys/commons

public static void main(String[] args){
    String s = "bla";
    DataByteArray dba = new DataByteArray();
    dba.set(s.getBytes());
    System.out.println(dba.toString());
  }
}

代码示例来源：origin: aseldawy/pigeon

@Override
 public DataByteArray exec(Tuple input) throws IOException {
  return new DataByteArray(extent(input).asBinary().array());
 }
}

代码示例来源：origin: Netflix/iceberg

@Override
 public DataByteArray read(DataByteArray reuse) {
  byte[] bytes = column.nextBinary().getBytes();
  return new DataByteArray(bytes);
 }
}

代码示例来源：origin: com.twitter.elephantbird/elephant-bird-pig

@Override
public Tuple getNext() throws IOException {
 byte[] bytes = getNextBinaryValue(typeRef);
 return bytes != null ?
   tupleFactory.newTuple(new DataByteArray(bytes)) : null;
}

代码示例来源：origin: aseldawy/pigeon

@Override
 public Tuple exec(Tuple input) throws IOException {
  return TupleFactory.getInstance().newTuple(
    new DataByteArray(convexHull(input).asBinary().array()));
 }
}

代码示例来源：origin: aseldawy/pigeon

@Override
public DataByteArray exec(Tuple input) throws IOException {
 Geometry geom = null;
 try {
  Object v = input.get(0);
  geom = GEOMETRY_PARSER.parseGeom(v);
  Geometry boundary = geom.getBoundary();
  return new DataByteArray(WKB_WRITER.write(boundary));
 } catch (ExecException e) {
  throw new GeoException(geom, e);
 }
}