Skip to content

Commit b557867

Browse files
Rename fixed size binary producer to match convention
1 parent 1ab4ff2 commit b557867

File tree

4 files changed

+10
-10
lines changed

4 files changed

+10
-10
lines changed

adapter/avro/src/main/java/org/apache/arrow/adapter/avro/ArrowToAvroUtils.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@
2222
import org.apache.arrow.adapter.avro.producers.AvroBooleanProducer;
2323
import org.apache.arrow.adapter.avro.producers.AvroBytesProducer;
2424
import org.apache.arrow.adapter.avro.producers.AvroDenseUnionProducer;
25-
import org.apache.arrow.adapter.avro.producers.AvroFixedProducer;
25+
import org.apache.arrow.adapter.avro.producers.AvroFixedSizeBinaryProducer;
2626
import org.apache.arrow.adapter.avro.producers.AvroFixedSizeListProducer;
2727
import org.apache.arrow.adapter.avro.producers.AvroFloat2Producer;
2828
import org.apache.arrow.adapter.avro.producers.AvroFloat4Producer;
@@ -620,7 +620,7 @@ private static BaseAvroProducer<?> createProducer(FieldVector vector, boolean nu
620620
case VARBINARY:
621621
return new AvroBytesProducer((VarBinaryVector) vector);
622622
case FIXEDSIZEBINARY:
623-
return new AvroFixedProducer((FixedSizeBinaryVector) vector);
623+
return new AvroFixedSizeBinaryProducer((FixedSizeBinaryVector) vector);
624624
case VARCHAR:
625625
return new AvroStringProducer((VarCharVector) vector);
626626

adapter/avro/src/main/java/org/apache/arrow/adapter/avro/producers/AvroFixedProducer.java renamed to adapter/avro/src/main/java/org/apache/arrow/adapter/avro/producers/AvroFixedSizeBinaryProducer.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -28,18 +28,18 @@
2828
* <p>Logical types are also supported, for vectors derived from {@link BaseFixedWidthVector} where
2929
* the internal representation is fixed width bytes and requires no conversion.
3030
*/
31-
public class AvroFixedProducer extends BaseAvroProducer<BaseFixedWidthVector> {
31+
public class AvroFixedSizeBinaryProducer extends BaseAvroProducer<BaseFixedWidthVector> {
3232

3333
private final byte[] reuseBytes;
3434

35-
/** Instantiate an AvroFixedProducer. */
36-
public AvroFixedProducer(FixedSizeBinaryVector vector) {
35+
/** Instantiate an AvroFixedSizeBinaryProducer. */
36+
public AvroFixedSizeBinaryProducer(FixedSizeBinaryVector vector) {
3737
super(vector);
3838
reuseBytes = new byte[vector.getTypeWidth()];
3939
}
4040

4141
/** Protected constructor for logical types with a fixed width representation. */
42-
protected AvroFixedProducer(BaseFixedWidthVector vector) {
42+
protected AvroFixedSizeBinaryProducer(BaseFixedWidthVector vector) {
4343
super(vector);
4444
reuseBytes = new byte[vector.getTypeWidth()];
4545
}

adapter/avro/src/main/java/org/apache/arrow/adapter/avro/producers/logical/AvroDecimal256Producer.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -16,14 +16,14 @@
1616
*/
1717
package org.apache.arrow.adapter.avro.producers.logical;
1818

19-
import org.apache.arrow.adapter.avro.producers.AvroFixedProducer;
19+
import org.apache.arrow.adapter.avro.producers.AvroFixedSizeBinaryProducer;
2020
import org.apache.arrow.vector.Decimal256Vector;
2121

2222
/**
2323
* Producer that produces decimal values from a {@link Decimal256Vector}, writes data to an Avro
2424
* encoder.
2525
*/
26-
public class AvroDecimal256Producer extends AvroFixedProducer {
26+
public class AvroDecimal256Producer extends AvroFixedSizeBinaryProducer {
2727

2828
// Decimal stored as fixed width bytes, matches Avro decimal encoding
2929

adapter/avro/src/main/java/org/apache/arrow/adapter/avro/producers/logical/AvroDecimalProducer.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -16,14 +16,14 @@
1616
*/
1717
package org.apache.arrow.adapter.avro.producers.logical;
1818

19-
import org.apache.arrow.adapter.avro.producers.AvroFixedProducer;
19+
import org.apache.arrow.adapter.avro.producers.AvroFixedSizeBinaryProducer;
2020
import org.apache.arrow.vector.DecimalVector;
2121

2222
/**
2323
* Producer that produces decimal values from a {@link DecimalVector}, writes data to an Avro
2424
* encoder.
2525
*/
26-
public class AvroDecimalProducer extends AvroFixedProducer {
26+
public class AvroDecimalProducer extends AvroFixedSizeBinaryProducer {
2727

2828
// Decimal stored as fixed width bytes, matches Avro decimal encoding
2929

0 commit comments

Comments
 (0)