Repository: avro Updated Branches: refs/heads/master 2e25d2edd -> a3e05bee1
AVRO-2117: Cleanup Java - Fix spelling errors Project: http://git-wip-us.apache.org/repos/asf/avro/repo Commit: http://git-wip-us.apache.org/repos/asf/avro/commit/4b69cb20 Tree: http://git-wip-us.apache.org/repos/asf/avro/tree/4b69cb20 Diff: http://git-wip-us.apache.org/repos/asf/avro/diff/4b69cb20 Branch: refs/heads/master Commit: 4b69cb20ad51d80b9404b505c4550dec1ba32df5 Parents: 2e25d2e Author: Niels Basjes <[email protected]> Authored: Wed Dec 13 14:56:00 2017 +0100 Committer: Niels Basjes <[email protected]> Committed: Fri Dec 29 14:42:14 2017 +0100 ---------------------------------------------------------------------- CHANGES.txt | 2 ++ .../avro/src/main/java/org/apache/avro/JsonProperties.java | 4 ++-- .../java/avro/src/main/java/org/apache/avro/LogicalType.java | 2 +- lang/java/avro/src/main/java/org/apache/avro/Schema.java | 2 +- .../avro/src/main/java/org/apache/avro/SchemaBuilder.java | 6 +++--- .../src/main/java/org/apache/avro/SchemaCompatibility.java | 4 ++-- .../src/main/java/org/apache/avro/SchemaNormalization.java | 6 +++--- .../avro/src/main/java/org/apache/avro/SchemaValidator.java | 2 +- lang/java/avro/src/main/java/org/apache/avro/file/Codec.java | 2 +- .../src/main/java/org/apache/avro/file/DataFileStream.java | 2 +- .../main/java/org/apache/avro/io/BlockingBinaryEncoder.java | 6 +++--- .../avro/src/main/java/org/apache/avro/io/JsonDecoder.java | 6 +++--- .../src/main/java/org/apache/avro/io/ResolvingDecoder.java | 2 +- .../apache/avro/io/parsing/ResolvingGrammarGenerator.java | 4 ++-- .../src/main/java/org/apache/avro/io/parsing/Symbol.java | 2 +- .../java/org/apache/avro/specific/ExternalizableInput.java | 2 +- .../java/org/apache/avro/specific/ExternalizableOutput.java | 2 +- .../test/java/org/apache/avro/TestSchemaNormalization.java | 2 +- .../test/java/org/apache/avro/file/codec/CustomCodec.java | 2 +- .../java/org/apache/avro/reflect/TestNonStringMapKeys.java | 4 ++-- .../java/org/apache/avro/compiler/idl/SchemaResolver.java | 2 +- .../java/org/apache/avro/compiler/schema/CloningVisitor.java | 2 +- .../src/test/java/org/apache/avro/compiler/idl/TestIdl.java | 2 +- .../apache/avro/compiler/specific/TestSpecificCompiler.java | 4 ++-- .../compiler/src/test/resources/union_and_fixed_fields.avsc | 2 +- .../ipc/src/main/java/org/apache/avro/ipc/NettyServer.java | 2 +- .../ipc/src/main/java/org/apache/avro/ipc/RPCContext.java | 2 +- .../ipc/src/main/java/org/apache/avro/ipc/Responder.java | 2 +- .../java/org/apache/avro/ipc/reflect/ReflectRequestor.java | 8 ++++---- .../java/org/apache/avro/ipc/specific/SpecificRequestor.java | 8 ++++---- .../src/test/java/org/apache/avro/DataFileInteropTest.java | 2 +- .../src/test/java/org/apache/avro/TestProtocolParsing.java | 2 +- .../java/org/apache/avro/hadoop/io/AvroDeserializer.java | 2 +- .../java/org/apache/avro/hadoop/io/AvroSequenceFile.java | 6 +++--- .../java/org/apache/avro/hadoop/io/AvroSerialization.java | 4 ++-- .../java/org/apache/avro/mapred/tether/TetheredProcess.java | 2 +- .../src/main/java/org/apache/avro/mapreduce/AvroJob.java | 2 +- .../java/org/apache/avro/mapred/TestAvroMultipleOutputs.java | 4 ++-- .../test/java/org/apache/avro/mapred/tether/TetherTask.java | 2 +- .../src/main/java/org/apache/avro/mojo/SchemaMojo.java | 2 +- .../test/java/org/apache/avro/mojo/AbstractAvroMojoTest.java | 2 +- .../test/java/org/apache/avro/tool/TestDataFileTools.java | 2 +- 42 files changed, 66 insertions(+), 64 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/avro/blob/4b69cb20/CHANGES.txt ---------------------------------------------------------------------- diff --git a/CHANGES.txt b/CHANGES.txt index 098e3bb..118ab09 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -105,6 +105,8 @@ Trunk (not yet released) AVRO-2119: Run Apache Rat check on every java build (Niels Basjes) + AVRO-2117: Overall cleanup of java code (Niels Basjes) + BUG FIXES AVRO-1741: Python3: Fix error when codec is not in the header. http://git-wip-us.apache.org/repos/asf/avro/blob/4b69cb20/lang/java/avro/src/main/java/org/apache/avro/JsonProperties.java ---------------------------------------------------------------------- diff --git a/lang/java/avro/src/main/java/org/apache/avro/JsonProperties.java b/lang/java/avro/src/main/java/org/apache/avro/JsonProperties.java index 4e18c09..c1d754f 100644 --- a/lang/java/avro/src/main/java/org/apache/avro/JsonProperties.java +++ b/lang/java/avro/src/main/java/org/apache/avro/JsonProperties.java @@ -209,7 +209,7 @@ public abstract class JsonProperties { } /** - * Return the defined properties as an unmodifieable Map. + * Return the defined properties as an unmodifiable Map. * @deprecated use {@link #getObjectProps()} */ @Deprecated @@ -217,7 +217,7 @@ public abstract class JsonProperties { return Collections.unmodifiableMap(props); } - /** Return the defined properties as an unmodifieable Map. */ + /** Return the defined properties as an unmodifiable Map. */ public Map<String,Object> getObjectProps() { Map<String,Object> result = new LinkedHashMap<String,Object>(); for (Map.Entry<String,JsonNode> e : props.entrySet()) http://git-wip-us.apache.org/repos/asf/avro/blob/4b69cb20/lang/java/avro/src/main/java/org/apache/avro/LogicalType.java ---------------------------------------------------------------------- diff --git a/lang/java/avro/src/main/java/org/apache/avro/LogicalType.java b/lang/java/avro/src/main/java/org/apache/avro/LogicalType.java index d701693..3bd8c0a 100644 --- a/lang/java/avro/src/main/java/org/apache/avro/LogicalType.java +++ b/lang/java/avro/src/main/java/org/apache/avro/LogicalType.java @@ -25,7 +25,7 @@ import org.apache.avro.specific.SpecificData; * Logical types provides an opt-in way to extend Avro's types. Logical types * specify a way of representing a high-level type as a base Avro type. For * example, a date is specified as the number of days after the unix epoch (or - * before using a negative value). This enables extentions to Avro's type + * before using a negative value). This enables extensions to Avro's type * system without breaking binary compatibility. Older versions see the base * type and ignore the logical type. */ http://git-wip-us.apache.org/repos/asf/avro/blob/4b69cb20/lang/java/avro/src/main/java/org/apache/avro/Schema.java ---------------------------------------------------------------------- diff --git a/lang/java/avro/src/main/java/org/apache/avro/Schema.java b/lang/java/avro/src/main/java/org/apache/avro/Schema.java index f01775d..474a69c 100644 --- a/lang/java/avro/src/main/java/org/apache/avro/Schema.java +++ b/lang/java/avro/src/main/java/org/apache/avro/Schema.java @@ -443,7 +443,7 @@ public abstract class Schema extends JsonProperties { this.aliases = new LinkedHashSet<String>(); aliases.add(alias); } - /** Return the defined aliases as an unmodifieable Set. */ + /** Return the defined aliases as an unmodifiable Set. */ public Set<String> aliases() { if (aliases == null) return Collections.emptySet(); http://git-wip-us.apache.org/repos/asf/avro/blob/4b69cb20/lang/java/avro/src/main/java/org/apache/avro/SchemaBuilder.java ---------------------------------------------------------------------- diff --git a/lang/java/avro/src/main/java/org/apache/avro/SchemaBuilder.java b/lang/java/avro/src/main/java/org/apache/avro/SchemaBuilder.java index ce038d4..00293ea 100644 --- a/lang/java/avro/src/main/java/org/apache/avro/SchemaBuilder.java +++ b/lang/java/avro/src/main/java/org/apache/avro/SchemaBuilder.java @@ -372,7 +372,7 @@ public class SchemaBuilder { * <p/> * All Avro named types and fields have 'doc', 'aliases', and 'name' * components. 'name' is required, and provided to this builder. 'doc' and - * 'alises' are optional. + * 'aliases' are optional. */ public static abstract class NamedBuilder<S extends NamedBuilder<S>> extends PropBuilder<S> { @@ -2027,7 +2027,7 @@ public class SchemaBuilder { * Usage is to first configure any of the optional parameters and then to call one * of the type methods to complete the field. For example * <pre> - * .namespace("org.apache.example").orderDecending().type() + * .namespace("org.apache.example").orderDescending().type() * </pre> * Optional parameters for a field are namespace, doc, order, and aliases. */ @@ -2047,7 +2047,7 @@ public class SchemaBuilder { return self(); } - /** Set this field to have decending order. Decending is the default **/ + /** Set this field to have descending order. Descending is the default **/ public FieldBuilder<R> orderDescending() { order = Schema.Field.Order.DESCENDING; return self(); http://git-wip-us.apache.org/repos/asf/avro/blob/4b69cb20/lang/java/avro/src/main/java/org/apache/avro/SchemaCompatibility.java ---------------------------------------------------------------------- diff --git a/lang/java/avro/src/main/java/org/apache/avro/SchemaCompatibility.java b/lang/java/avro/src/main/java/org/apache/avro/SchemaCompatibility.java index aa5041e..8453579 100644 --- a/lang/java/avro/src/main/java/org/apache/avro/SchemaCompatibility.java +++ b/lang/java/avro/src/main/java/org/apache/avro/SchemaCompatibility.java @@ -61,7 +61,7 @@ public class SchemaCompatibility { final Schema writer ) { final SchemaCompatibilityResult compatibility = - new ReaderWriterCompatiblityChecker() + new ReaderWriterCompatibilityChecker() .getCompatibility(reader, writer); final String message; @@ -194,7 +194,7 @@ public class SchemaCompatibility { * * <p> Provides memoization to handle recursive schemas. </p> */ - private static final class ReaderWriterCompatiblityChecker { + private static final class ReaderWriterCompatibilityChecker { private static final String ROOT_REFERENCE_TOKEN = ""; private final Map<ReaderWriter, SchemaCompatibilityResult> mMemoizeMap = new HashMap<ReaderWriter, SchemaCompatibilityResult>(); http://git-wip-us.apache.org/repos/asf/avro/blob/4b69cb20/lang/java/avro/src/main/java/org/apache/avro/SchemaNormalization.java ---------------------------------------------------------------------- diff --git a/lang/java/avro/src/main/java/org/apache/avro/SchemaNormalization.java b/lang/java/avro/src/main/java/org/apache/avro/SchemaNormalization.java index 16d2642..58c642d 100644 --- a/lang/java/avro/src/main/java/org/apache/avro/SchemaNormalization.java +++ b/lang/java/avro/src/main/java/org/apache/avro/SchemaNormalization.java @@ -24,8 +24,8 @@ import java.io.UnsupportedEncodingException; import java.security.MessageDigest; import java.security.NoSuchAlgorithmException; -/** Collection of static methods for generating the cannonical form of - * schemas (see {@link #toParsingForm}) -- and fingerprints of cannonical +/** Collection of static methods for generating the canonical form of + * schemas (see {@link #toParsingForm}) -- and fingerprints of canonical * forms ({@link #fingerprint}). */ public class SchemaNormalization { @@ -54,7 +54,7 @@ public class SchemaNormalization { * MessageDigest#getInstance(String)}, which will throw * <code>NoSuchAlgorithmException</code> if it doesn't recognize * the name. - * <p> Recommended Avro practice dictiates that + * <p> Recommended Avro practice dictates that * <code>"CRC-64-AVRO"</code> is used for 64-bit fingerprints, * <code>"MD5"</code> is used for 128-bit fingerprints, and * <code>"SHA-256"</code> is used for 256-bit fingerprints. */ http://git-wip-us.apache.org/repos/asf/avro/blob/4b69cb20/lang/java/avro/src/main/java/org/apache/avro/SchemaValidator.java ---------------------------------------------------------------------- diff --git a/lang/java/avro/src/main/java/org/apache/avro/SchemaValidator.java b/lang/java/avro/src/main/java/org/apache/avro/SchemaValidator.java index af85bac..27e4b5e 100644 --- a/lang/java/avro/src/main/java/org/apache/avro/SchemaValidator.java +++ b/lang/java/avro/src/main/java/org/apache/avro/SchemaValidator.java @@ -34,7 +34,7 @@ public interface SchemaValidator { * Validate one schema against others. The order of the schemas to validate * against is chronological from most recent to oldest, if there is a natural * chronological order. This allows some validators to identify which schemas - * are the most "recent" in order to validate only against the mosst recent + * are the most "recent" in order to validate only against the most recent * schema(s). * * @param toValidate The schema to validate http://git-wip-us.apache.org/repos/asf/avro/blob/4b69cb20/lang/java/avro/src/main/java/org/apache/avro/file/Codec.java ---------------------------------------------------------------------- diff --git a/lang/java/avro/src/main/java/org/apache/avro/file/Codec.java b/lang/java/avro/src/main/java/org/apache/avro/file/Codec.java index c27b4b7..cd67db0 100644 --- a/lang/java/avro/src/main/java/org/apache/avro/file/Codec.java +++ b/lang/java/avro/src/main/java/org/apache/avro/file/Codec.java @@ -33,7 +33,7 @@ public abstract class Codec { /** * Codecs must implement an equals() method. Two codecs, A and B are equal * if: the result of A and B decompressing content compressed by A is the same - * AND the retult of A and B decompressing content compressed by B is the same + * AND the result of A and B decompressing content compressed by B is the same **/ @Override public abstract boolean equals(Object other); http://git-wip-us.apache.org/repos/asf/avro/blob/4b69cb20/lang/java/avro/src/main/java/org/apache/avro/file/DataFileStream.java ---------------------------------------------------------------------- diff --git a/lang/java/avro/src/main/java/org/apache/avro/file/DataFileStream.java b/lang/java/avro/src/main/java/org/apache/avro/file/DataFileStream.java index 0a27476..e546adf 100644 --- a/lang/java/avro/src/main/java/org/apache/avro/file/DataFileStream.java +++ b/lang/java/avro/src/main/java/org/apache/avro/file/DataFileStream.java @@ -85,7 +85,7 @@ public class DataFileStream<D> implements Iterator<D>, Iterable<D>, Closeable { } /** - * create an unitialized DataFileStream + * create an uninitialized DataFileStream */ protected DataFileStream(DatumReader<D> reader) throws IOException { this.reader = reader; http://git-wip-us.apache.org/repos/asf/avro/blob/4b69cb20/lang/java/avro/src/main/java/org/apache/avro/io/BlockingBinaryEncoder.java ---------------------------------------------------------------------- diff --git a/lang/java/avro/src/main/java/org/apache/avro/io/BlockingBinaryEncoder.java b/lang/java/avro/src/main/java/org/apache/avro/io/BlockingBinaryEncoder.java index 96a055d..8bc0700 100644 --- a/lang/java/avro/src/main/java/org/apache/avro/io/BlockingBinaryEncoder.java +++ b/lang/java/avro/src/main/java/org/apache/avro/io/BlockingBinaryEncoder.java @@ -137,9 +137,9 @@ public class BlockingBinaryEncoder extends BufferedBinaryEncoder { type == Schema.Type.ARRAY || type == Schema.Type.MAP); assert 0 <= items; - assert 0 != items || start == pos; // 0==itms ==> start==pos - assert 1 < items || start == lastFullItem; // 1<=itms ==> start==lFI - assert items <= 1 || start <= lastFullItem; // 1<itms ==> start<=lFI + assert 0 != items || start == pos; // 0==items ==> start==pos + assert 1 < items || start == lastFullItem; // 1<=items ==> start==lFI + assert items <= 1 || start <= lastFullItem; // 1<items ==> start<=lFI assert lastFullItem <= pos; switch (state) { http://git-wip-us.apache.org/repos/asf/avro/blob/4b69cb20/lang/java/avro/src/main/java/org/apache/avro/io/JsonDecoder.java ---------------------------------------------------------------------- diff --git a/lang/java/avro/src/main/java/org/apache/avro/io/JsonDecoder.java b/lang/java/avro/src/main/java/org/apache/avro/io/JsonDecoder.java index 78fafaa..890cc63 100644 --- a/lang/java/avro/src/main/java/org/apache/avro/io/JsonDecoder.java +++ b/lang/java/avro/src/main/java/org/apache/avro/io/JsonDecoder.java @@ -96,7 +96,7 @@ public class JsonDecoder extends ParsingDecoder * Otherwise, this JsonDecoder will reset its state and then * reconfigure its input. * @param in - * The IntputStream to read from. Cannot be null. + * The InputStream to read from. Cannot be null. * @throws IOException * @return this JsonDecoder */ @@ -475,7 +475,7 @@ public class JsonDecoder extends ParsingDecoder if (currentReorderBuffer == null) { currentReorderBuffer = new ReorderBuffer(); } - currentReorderBuffer.savedFields.put(fn, getVaueAsTree(in)); + currentReorderBuffer.savedFields.put(fn, getValueAsTree(in)); } } while (in.getCurrentToken() == JsonToken.FIELD_NAME); throw new AvroTypeException("Expected field name not found: " + fa.fname); @@ -524,7 +524,7 @@ public class JsonDecoder extends ParsingDecoder } } - private static List<JsonElement> getVaueAsTree(JsonParser in) throws IOException { + private static List<JsonElement> getValueAsTree(JsonParser in) throws IOException { int level = 0; List<JsonElement> result = new ArrayList<JsonElement>(); do { http://git-wip-us.apache.org/repos/asf/avro/blob/4b69cb20/lang/java/avro/src/main/java/org/apache/avro/io/ResolvingDecoder.java ---------------------------------------------------------------------- diff --git a/lang/java/avro/src/main/java/org/apache/avro/io/ResolvingDecoder.java b/lang/java/avro/src/main/java/org/apache/avro/io/ResolvingDecoder.java index 02cad1f..7a5a5e5 100644 --- a/lang/java/avro/src/main/java/org/apache/avro/io/ResolvingDecoder.java +++ b/lang/java/avro/src/main/java/org/apache/avro/io/ResolvingDecoder.java @@ -71,7 +71,7 @@ public class ResolvingDecoder extends ValidatingDecoder { * * @param writer The writer's schema. Cannot be null. * @param reader The reader's schema. Cannot be null. - * @return The opaque reolver. + * @return The opaque resolver. * @throws IOException */ public static Object resolve(Schema writer, Schema reader) http://git-wip-us.apache.org/repos/asf/avro/blob/4b69cb20/lang/java/avro/src/main/java/org/apache/avro/io/parsing/ResolvingGrammarGenerator.java ---------------------------------------------------------------------- diff --git a/lang/java/avro/src/main/java/org/apache/avro/io/parsing/ResolvingGrammarGenerator.java b/lang/java/avro/src/main/java/org/apache/avro/io/parsing/ResolvingGrammarGenerator.java index 5407327..7dfe3c2 100644 --- a/lang/java/avro/src/main/java/org/apache/avro/io/parsing/ResolvingGrammarGenerator.java +++ b/lang/java/avro/src/main/java/org/apache/avro/io/parsing/ResolvingGrammarGenerator.java @@ -55,7 +55,7 @@ public class ResolvingGrammarGenerator extends ValidatingGrammarGenerator { * <tt>reader</tt> and returns the start symbol for the grammar generated. * If there is already a symbol in the map <tt>seen</tt> for resolving the * two schemas, then that symbol is returned. Otherwise a new symbol is - * generated and returnd. + * generated and returned. * @param writer The schema used by the writer * @param reader The schema used by the reader * @param seen The <reader-schema, writer-schema> to symbol @@ -119,7 +119,7 @@ public class ResolvingGrammarGenerator extends ValidatingGrammarGenerator { case UNION: return resolveUnion(writer, reader, seen); default: - throw new AvroTypeException("Unkown type for schema: " + writerType); + throw new AvroTypeException("Unknown type for schema: " + writerType); } } else { // writer and reader are of different types if (writerType == Schema.Type.UNION) { http://git-wip-us.apache.org/repos/asf/avro/blob/4b69cb20/lang/java/avro/src/main/java/org/apache/avro/io/parsing/Symbol.java ---------------------------------------------------------------------- diff --git a/lang/java/avro/src/main/java/org/apache/avro/io/parsing/Symbol.java b/lang/java/avro/src/main/java/org/apache/avro/io/parsing/Symbol.java index f33c292..a284f65 100644 --- a/lang/java/avro/src/main/java/org/apache/avro/io/parsing/Symbol.java +++ b/lang/java/avro/src/main/java/org/apache/avro/io/parsing/Symbol.java @@ -41,7 +41,7 @@ public abstract class Symbol { ROOT, /** non-terminal symbol which is a sequence of one or more other symbols */ SEQUENCE, - /** non-termial to represent the contents of an array or map */ + /** non-terminal to represent the contents of an array or map */ REPEATER, /** non-terminal to represent the union */ ALTERNATIVE, http://git-wip-us.apache.org/repos/asf/avro/blob/4b69cb20/lang/java/avro/src/main/java/org/apache/avro/specific/ExternalizableInput.java ---------------------------------------------------------------------- diff --git a/lang/java/avro/src/main/java/org/apache/avro/specific/ExternalizableInput.java b/lang/java/avro/src/main/java/org/apache/avro/specific/ExternalizableInput.java index d09c449..9e9596d 100644 --- a/lang/java/avro/src/main/java/org/apache/avro/specific/ExternalizableInput.java +++ b/lang/java/avro/src/main/java/org/apache/avro/specific/ExternalizableInput.java @@ -22,7 +22,7 @@ import java.io.InputStream; import java.io.IOException; import java.io.ObjectInput; -/** Helper to permit Externalizeable implementations that write to an +/** Helper to permit Externalizable implementations that write to an * InputStream. */ class ExternalizableInput extends InputStream { private final ObjectInput in; http://git-wip-us.apache.org/repos/asf/avro/blob/4b69cb20/lang/java/avro/src/main/java/org/apache/avro/specific/ExternalizableOutput.java ---------------------------------------------------------------------- diff --git a/lang/java/avro/src/main/java/org/apache/avro/specific/ExternalizableOutput.java b/lang/java/avro/src/main/java/org/apache/avro/specific/ExternalizableOutput.java index aa90e61..172af67 100644 --- a/lang/java/avro/src/main/java/org/apache/avro/specific/ExternalizableOutput.java +++ b/lang/java/avro/src/main/java/org/apache/avro/specific/ExternalizableOutput.java @@ -22,7 +22,7 @@ import java.io.OutputStream; import java.io.IOException; import java.io.ObjectOutput; -/** Helper to permit Externalizeable implementations that write to an +/** Helper to permit Externalizable implementations that write to an * OutputStream. */ class ExternalizableOutput extends OutputStream { private final ObjectOutput out; http://git-wip-us.apache.org/repos/asf/avro/blob/4b69cb20/lang/java/avro/src/test/java/org/apache/avro/TestSchemaNormalization.java ---------------------------------------------------------------------- diff --git a/lang/java/avro/src/test/java/org/apache/avro/TestSchemaNormalization.java b/lang/java/avro/src/test/java/org/apache/avro/TestSchemaNormalization.java index cb8a6d7..f05bf90 100644 --- a/lang/java/avro/src/test/java/org/apache/avro/TestSchemaNormalization.java +++ b/lang/java/avro/src/test/java/org/apache/avro/TestSchemaNormalization.java @@ -99,7 +99,7 @@ public class TestSchemaNormalization { /** Compute the fingerprint of <i>bytes[s,s+l)</i> using a slow algorithm that's an alternative to that implemented in {@link SchemaNormalization}. Algo from Broder93 ("Some applications of Rabin's - fingerpringint method"). */ + fingerprinting method"). */ public static long altFingerprint(String s) { // In our algorithm, we multiply all inputs by x^64 (which is // equivalent to prepending it with a single "1" bit followed http://git-wip-us.apache.org/repos/asf/avro/blob/4b69cb20/lang/java/avro/src/test/java/org/apache/avro/file/codec/CustomCodec.java ---------------------------------------------------------------------- diff --git a/lang/java/avro/src/test/java/org/apache/avro/file/codec/CustomCodec.java b/lang/java/avro/src/test/java/org/apache/avro/file/codec/CustomCodec.java index 7ff4bcf..9738253 100644 --- a/lang/java/avro/src/test/java/org/apache/avro/file/codec/CustomCodec.java +++ b/lang/java/avro/src/test/java/org/apache/avro/file/codec/CustomCodec.java @@ -72,7 +72,7 @@ public class CustomCodec extends Codec { /** * Codecs must implement an equals() method. Two codecs, A and B are equal * if: the result of A and B decompressing content compressed by A is the same - * AND the retult of A and B decompressing content compressed by B is the same + * AND the result of A and B decompressing content compressed by B is the same */ private boolean compareDecompress(Codec other, ByteBuffer original) throws IOException { ByteBuffer compressedA = this.compress(original); http://git-wip-us.apache.org/repos/asf/avro/blob/4b69cb20/lang/java/avro/src/test/java/org/apache/avro/reflect/TestNonStringMapKeys.java ---------------------------------------------------------------------- diff --git a/lang/java/avro/src/test/java/org/apache/avro/reflect/TestNonStringMapKeys.java b/lang/java/avro/src/test/java/org/apache/avro/reflect/TestNonStringMapKeys.java index 26c7bba..3a1d3d4 100644 --- a/lang/java/avro/src/test/java/org/apache/avro/reflect/TestNonStringMapKeys.java +++ b/lang/java/avro/src/test/java/org/apache/avro/reflect/TestNonStringMapKeys.java @@ -264,7 +264,7 @@ public class TestNonStringMapKeys { /** * Test that non-string map-keys are readable through GenericDatumReader - * This methoud should read as array of {key, value} and not as a map + * This method should read as array of {key, value} and not as a map */ private <T> List<GenericRecord> testGenericDatumRead (String testType, byte[] bytes, T ... entityObjs) throws IOException { @@ -287,7 +287,7 @@ public class TestNonStringMapKeys { /** * Test that non-string map-keys are readable through ReflectDatumReader - * This methoud should form the original map and should not return any + * This method should form the original map and should not return any * array of {key, value} as done by {@link #testGenericDatumRead()} */ private <T> List<T> testReflectDatumRead http://git-wip-us.apache.org/repos/asf/avro/blob/4b69cb20/lang/java/compiler/src/main/java/org/apache/avro/compiler/idl/SchemaResolver.java ---------------------------------------------------------------------- diff --git a/lang/java/compiler/src/main/java/org/apache/avro/compiler/idl/SchemaResolver.java b/lang/java/compiler/src/main/java/org/apache/avro/compiler/idl/SchemaResolver.java index a3860e3..ba6dcb3 100644 --- a/lang/java/compiler/src/main/java/org/apache/avro/compiler/idl/SchemaResolver.java +++ b/lang/java/compiler/src/main/java/org/apache/avro/compiler/idl/SchemaResolver.java @@ -100,7 +100,7 @@ final class SchemaResolver { } result.setTypes(newSchemas); // replace types with resolved ones - // Resolve all schemas refferenced by protocol Messages. + // Resolve all schemas referenced by protocol Messages. for (Map.Entry<String, Protocol.Message> entry : protocol.getMessages().entrySet()) { Protocol.Message value = entry.getValue(); Protocol.Message nvalue; http://git-wip-us.apache.org/repos/asf/avro/blob/4b69cb20/lang/java/compiler/src/main/java/org/apache/avro/compiler/schema/CloningVisitor.java ---------------------------------------------------------------------- diff --git a/lang/java/compiler/src/main/java/org/apache/avro/compiler/schema/CloningVisitor.java b/lang/java/compiler/src/main/java/org/apache/avro/compiler/schema/CloningVisitor.java index ef2a53e..6da8d23 100644 --- a/lang/java/compiler/src/main/java/org/apache/avro/compiler/schema/CloningVisitor.java +++ b/lang/java/compiler/src/main/java/org/apache/avro/compiler/schema/CloningVisitor.java @@ -26,7 +26,7 @@ import org.apache.avro.Schema; import static org.apache.avro.Schema.Type.RECORD; /** - * this visitor will create a clone of the original Schema with docs and other nonesential fields stripped + * this visitor will create a clone of the original Schema with docs and other nonessential fields stripped * by default. what attributes are copied is customizable. */ public final class CloningVisitor implements SchemaVisitor<Schema> { http://git-wip-us.apache.org/repos/asf/avro/blob/4b69cb20/lang/java/compiler/src/test/java/org/apache/avro/compiler/idl/TestIdl.java ---------------------------------------------------------------------- diff --git a/lang/java/compiler/src/test/java/org/apache/avro/compiler/idl/TestIdl.java b/lang/java/compiler/src/test/java/org/apache/avro/compiler/idl/TestIdl.java index 52403a2..233769e 100644 --- a/lang/java/compiler/src/test/java/org/apache/avro/compiler/idl/TestIdl.java +++ b/lang/java/compiler/src/test/java/org/apache/avro/compiler/idl/TestIdl.java @@ -117,7 +117,7 @@ public class TestIdl { /** - * An invididual comparison test + * An individual comparison test */ private static class GenTest { private final File in, expectedOut; http://git-wip-us.apache.org/repos/asf/avro/blob/4b69cb20/lang/java/compiler/src/test/java/org/apache/avro/compiler/specific/TestSpecificCompiler.java ---------------------------------------------------------------------- diff --git a/lang/java/compiler/src/test/java/org/apache/avro/compiler/specific/TestSpecificCompiler.java b/lang/java/compiler/src/test/java/org/apache/avro/compiler/specific/TestSpecificCompiler.java index 50adb19..ae24847 100644 --- a/lang/java/compiler/src/test/java/org/apache/avro/compiler/specific/TestSpecificCompiler.java +++ b/lang/java/compiler/src/test/java/org/apache/avro/compiler/specific/TestSpecificCompiler.java @@ -107,7 +107,7 @@ public class TestSpecificCompiler { public void report(Diagnostic<? extends JavaFileObject> diagnostic) { switch (diagnostic.getKind()) { case ERROR: - // Do not add these to warnings becuase they will fail the compile, anyway. + // Do not add these to warnings because they will fail the compile, anyway. LOG.error("{}", diagnostic); break; case WARNING: @@ -325,7 +325,7 @@ public class TestSpecificCompiler { is.read(fileInDefaultEncoding); is.close(); //close input stream otherwise delete might fail if (!this.outputFile.delete()) { - throw new IllegalStateException("unable to delete " + this.outputFile); //delete otherwise compiler might not overwrite because src timestamp hasnt changed. + throw new IllegalStateException("unable to delete " + this.outputFile); //delete otherwise compiler might not overwrite because src timestamp hasn't changed. } // Generate file in another encoding (make sure it has different number of bytes per character) String differentEncoding = Charset.defaultCharset().equals(Charset.forName("UTF-16")) ? "UTF-32" : "UTF-16"; http://git-wip-us.apache.org/repos/asf/avro/blob/4b69cb20/lang/java/compiler/src/test/resources/union_and_fixed_fields.avsc ---------------------------------------------------------------------- diff --git a/lang/java/compiler/src/test/resources/union_and_fixed_fields.avsc b/lang/java/compiler/src/test/resources/union_and_fixed_fields.avsc index c584d6a..4e05540 100644 --- a/lang/java/compiler/src/test/resources/union_and_fixed_fields.avsc +++ b/lang/java/compiler/src/test/resources/union_and_fixed_fields.avsc @@ -1,7 +1,7 @@ { "type" : "record", "name" : "UnionAndFixedFields", - "doc" : "Schema for UnionAndFixedFields designed to trigger fixed compiler warnings in genrated code", + "doc" : "Schema for UnionAndFixedFields designed to trigger fixed compiler warnings in generated code", "namespace" : "org.apache.avro.specific", "fields" : [ { "name" : "u", http://git-wip-us.apache.org/repos/asf/avro/blob/4b69cb20/lang/java/ipc/src/main/java/org/apache/avro/ipc/NettyServer.java ---------------------------------------------------------------------- diff --git a/lang/java/ipc/src/main/java/org/apache/avro/ipc/NettyServer.java b/lang/java/ipc/src/main/java/org/apache/avro/ipc/NettyServer.java index 534f0bf..03d4468 100644 --- a/lang/java/ipc/src/main/java/org/apache/avro/ipc/NettyServer.java +++ b/lang/java/ipc/src/main/java/org/apache/avro/ipc/NettyServer.java @@ -192,7 +192,7 @@ public class NettyServer implements Server { e.getChannel().write(dataPack); } } catch (IOException ex) { - LOG.warn("unexpect error"); + LOG.warn("unexpected error"); } } http://git-wip-us.apache.org/repos/asf/avro/blob/4b69cb20/lang/java/ipc/src/main/java/org/apache/avro/ipc/RPCContext.java ---------------------------------------------------------------------- diff --git a/lang/java/ipc/src/main/java/org/apache/avro/ipc/RPCContext.java b/lang/java/ipc/src/main/java/org/apache/avro/ipc/RPCContext.java index 9eeefc4..f56279f 100644 --- a/lang/java/ipc/src/main/java/org/apache/avro/ipc/RPCContext.java +++ b/lang/java/ipc/src/main/java/org/apache/avro/ipc/RPCContext.java @@ -155,7 +155,7 @@ public class RPCContext { /** * The exception generated at the server, - * or null if no such exception has occured + * or null if no such exception has occurred * @return the exception generated at the server, or * null if no such exception */ http://git-wip-us.apache.org/repos/asf/avro/blob/4b69cb20/lang/java/ipc/src/main/java/org/apache/avro/ipc/Responder.java ---------------------------------------------------------------------- diff --git a/lang/java/ipc/src/main/java/org/apache/avro/ipc/Responder.java b/lang/java/ipc/src/main/java/org/apache/avro/ipc/Responder.java index 322c3fb..4f6ae2a 100644 --- a/lang/java/ipc/src/main/java/org/apache/avro/ipc/Responder.java +++ b/lang/java/ipc/src/main/java/org/apache/avro/ipc/Responder.java @@ -100,7 +100,7 @@ public abstract class Responder { } /** Called by a server to deserialize a request, compute and serialize a - * response or error. Transciever is used by connection-based servers to + * response or error. Transceiver is used by connection-based servers to * track handshake status of connection. */ public List<ByteBuffer> respond(List<ByteBuffer> buffers, Transceiver connection) throws IOException { http://git-wip-us.apache.org/repos/asf/avro/blob/4b69cb20/lang/java/ipc/src/main/java/org/apache/avro/ipc/reflect/ReflectRequestor.java ---------------------------------------------------------------------- diff --git a/lang/java/ipc/src/main/java/org/apache/avro/ipc/reflect/ReflectRequestor.java b/lang/java/ipc/src/main/java/org/apache/avro/ipc/reflect/ReflectRequestor.java index 29903ec..8ac26ca 100644 --- a/lang/java/ipc/src/main/java/org/apache/avro/ipc/reflect/ReflectRequestor.java +++ b/lang/java/ipc/src/main/java/org/apache/avro/ipc/reflect/ReflectRequestor.java @@ -69,21 +69,21 @@ public class ReflectRequestor extends SpecificRequestor { } /** Create a proxy instance whose methods invoke RPCs. */ - public static <T> T getClient(Class<T> iface, Transceiver transciever) + public static <T> T getClient(Class<T> iface, Transceiver transceiver) throws IOException { - return getClient(iface, transciever, + return getClient(iface, transceiver, new ReflectData(iface.getClassLoader())); } /** Create a proxy instance whose methods invoke RPCs. */ @SuppressWarnings("unchecked") - public static <T> T getClient(Class<T> iface, Transceiver transciever, + public static <T> T getClient(Class<T> iface, Transceiver transceiver, ReflectData reflectData) throws IOException { Protocol protocol = reflectData.getProtocol(iface); return (T)Proxy.newProxyInstance (reflectData.getClassLoader(), new Class[] { iface }, - new ReflectRequestor(protocol, transciever, reflectData)); + new ReflectRequestor(protocol, transceiver, reflectData)); } /** Create a proxy instance whose methods invoke RPCs. */ http://git-wip-us.apache.org/repos/asf/avro/blob/4b69cb20/lang/java/ipc/src/main/java/org/apache/avro/ipc/specific/SpecificRequestor.java ---------------------------------------------------------------------- diff --git a/lang/java/ipc/src/main/java/org/apache/avro/ipc/specific/SpecificRequestor.java b/lang/java/ipc/src/main/java/org/apache/avro/ipc/specific/SpecificRequestor.java index 5bcddc3..421d9bc 100644 --- a/lang/java/ipc/src/main/java/org/apache/avro/ipc/specific/SpecificRequestor.java +++ b/lang/java/ipc/src/main/java/org/apache/avro/ipc/specific/SpecificRequestor.java @@ -174,22 +174,22 @@ public class SpecificRequestor extends Requestor implements InvocationHandler { } /** Create a proxy instance whose methods invoke RPCs. */ - public static <T> T getClient(Class<T> iface, Transceiver transciever) + public static <T> T getClient(Class<T> iface, Transceiver transceiver) throws IOException { - return getClient(iface, transciever, + return getClient(iface, transceiver, new SpecificData(iface.getClassLoader())); } /** Create a proxy instance whose methods invoke RPCs. */ @SuppressWarnings("unchecked") - public static <T> T getClient(Class<T> iface, Transceiver transciever, + public static <T> T getClient(Class<T> iface, Transceiver transceiver, SpecificData data) throws IOException { Protocol protocol = data.getProtocol(iface); return (T)Proxy.newProxyInstance (data.getClassLoader(), new Class[] { iface }, - new SpecificRequestor(protocol, transciever, data)); + new SpecificRequestor(protocol, transceiver, data)); } /** Create a proxy instance whose methods invoke RPCs. */ http://git-wip-us.apache.org/repos/asf/avro/blob/4b69cb20/lang/java/ipc/src/test/java/org/apache/avro/DataFileInteropTest.java ---------------------------------------------------------------------- diff --git a/lang/java/ipc/src/test/java/org/apache/avro/DataFileInteropTest.java b/lang/java/ipc/src/test/java/org/apache/avro/DataFileInteropTest.java index 60862e2..e9582d6 100644 --- a/lang/java/ipc/src/test/java/org/apache/avro/DataFileInteropTest.java +++ b/lang/java/ipc/src/test/java/org/apache/avro/DataFileInteropTest.java @@ -64,7 +64,7 @@ public class DataFileInteropTest { } // Can't use same Interop.java as specific for reflect. - // This used to be the case because one used Utf8 and the other Sring, but + // This used to be the case because one used Utf8 and the other String, but // we use CharSequence now. // The current incompatibility is now that one uses byte[] and the other ByteBuffer http://git-wip-us.apache.org/repos/asf/avro/blob/4b69cb20/lang/java/ipc/src/test/java/org/apache/avro/TestProtocolParsing.java ---------------------------------------------------------------------- diff --git a/lang/java/ipc/src/test/java/org/apache/avro/TestProtocolParsing.java b/lang/java/ipc/src/test/java/org/apache/avro/TestProtocolParsing.java index 208a3d9..9a1c0a3 100644 --- a/lang/java/ipc/src/test/java/org/apache/avro/TestProtocolParsing.java +++ b/lang/java/ipc/src/test/java/org/apache/avro/TestProtocolParsing.java @@ -54,7 +54,7 @@ public class TestProtocolParsing { @Test public void oneWay() throws Exception { Message m; - // permit one-way messages w/ null resposne + // permit one-way messages w/ null response m = parseMessage("\"ack\": {" +"\"request\": []," +"\"response\": \"null\"," http://git-wip-us.apache.org/repos/asf/avro/blob/4b69cb20/lang/java/mapred/src/main/java/org/apache/avro/hadoop/io/AvroDeserializer.java ---------------------------------------------------------------------- diff --git a/lang/java/mapred/src/main/java/org/apache/avro/hadoop/io/AvroDeserializer.java b/lang/java/mapred/src/main/java/org/apache/avro/hadoop/io/AvroDeserializer.java index c11cd1c..7b6031d 100644 --- a/lang/java/mapred/src/main/java/org/apache/avro/hadoop/io/AvroDeserializer.java +++ b/lang/java/mapred/src/main/java/org/apache/avro/hadoop/io/AvroDeserializer.java @@ -33,7 +33,7 @@ import org.apache.hadoop.io.serializer.Deserializer; /** * Deserializes AvroWrapper objects within Hadoop. * - * <p>Keys and values containing Avro tyeps are more efficiently serialized + * <p>Keys and values containing Avro types are more efficiently serialized * outside of the WritableSerialization model, so they are wrapper in {@link * org.apache.avro.mapred.AvroWrapper} objects and deserialization is handled * by this class.</p> http://git-wip-us.apache.org/repos/asf/avro/blob/4b69cb20/lang/java/mapred/src/main/java/org/apache/avro/hadoop/io/AvroSequenceFile.java ---------------------------------------------------------------------- diff --git a/lang/java/mapred/src/main/java/org/apache/avro/hadoop/io/AvroSequenceFile.java b/lang/java/mapred/src/main/java/org/apache/avro/hadoop/io/AvroSequenceFile.java index 36fc454..a455bf4 100644 --- a/lang/java/mapred/src/main/java/org/apache/avro/hadoop/io/AvroSequenceFile.java +++ b/lang/java/mapred/src/main/java/org/apache/avro/hadoop/io/AvroSequenceFile.java @@ -74,10 +74,10 @@ import static org.apache.hadoop.fs.CommonConfigurationKeysPublic.IO_FILE_BUFFER_ public class AvroSequenceFile { private static final Logger LOG = LoggerFactory.getLogger(AvroSequenceFile.class); - /** The SequencFile.Metadata field for the Avro key writer schema. */ + /** The SequenceFile.Metadata field for the Avro key writer schema. */ public static final Text METADATA_FIELD_KEY_SCHEMA = new Text("avro.key.schema"); - /** The SequencFile.Metadata field for the Avro value writer schema. */ + /** The SequenceFile.Metadata field for the Avro value writer schema. */ public static final Text METADATA_FIELD_VALUE_SCHEMA = new Text("avro.value.schema"); /** Constructor disabled for this container class. */ @@ -446,7 +446,7 @@ public class AvroSequenceFile { /** * Gets the desired number of replicas to store for each block of the file. * - * @return The replciation factor for the blocks of the file. + * @return The replication factor for the blocks of the file. */ public short getReplicationFactor() { if (DEFAULT == mReplicationFactor) { http://git-wip-us.apache.org/repos/asf/avro/blob/4b69cb20/lang/java/mapred/src/main/java/org/apache/avro/hadoop/io/AvroSerialization.java ---------------------------------------------------------------------- diff --git a/lang/java/mapred/src/main/java/org/apache/avro/hadoop/io/AvroSerialization.java b/lang/java/mapred/src/main/java/org/apache/avro/hadoop/io/AvroSerialization.java index dda7543..b7c4b7c 100644 --- a/lang/java/mapred/src/main/java/org/apache/avro/hadoop/io/AvroSerialization.java +++ b/lang/java/mapred/src/main/java/org/apache/avro/hadoop/io/AvroSerialization.java @@ -177,7 +177,7 @@ public class AvroSerialization<T> extends Configured implements Serialization<Av } /** - * Sets the data model class for de/seralization. + * Sets the data model class for de/serialization. * * @param conf The configuration. * @param modelClass The data model class. @@ -231,7 +231,7 @@ public class AvroSerialization<T> extends Configured implements Serialization<Av } /** - * Gets the data model class for de/seralization. + * Gets the data model class for de/serialization. * * @param conf The configuration. */ http://git-wip-us.apache.org/repos/asf/avro/blob/4b69cb20/lang/java/mapred/src/main/java/org/apache/avro/mapred/tether/TetheredProcess.java ---------------------------------------------------------------------- diff --git a/lang/java/mapred/src/main/java/org/apache/avro/mapred/tether/TetheredProcess.java b/lang/java/mapred/src/main/java/org/apache/avro/mapred/tether/TetheredProcess.java index 142905a..e9be9e5 100644 --- a/lang/java/mapred/src/main/java/org/apache/avro/mapred/tether/TetheredProcess.java +++ b/lang/java/mapred/src/main/java/org/apache/avro/mapred/tether/TetheredProcess.java @@ -97,7 +97,7 @@ class TetheredProcess { break; case NONE: default: - throw new RuntimeException("No transport protocol was specified in the job configuraiton"); + throw new RuntimeException("No transport protocol was specified in the job configuration"); } outputServer.start(); http://git-wip-us.apache.org/repos/asf/avro/blob/4b69cb20/lang/java/mapred/src/main/java/org/apache/avro/mapreduce/AvroJob.java ---------------------------------------------------------------------- diff --git a/lang/java/mapred/src/main/java/org/apache/avro/mapreduce/AvroJob.java b/lang/java/mapred/src/main/java/org/apache/avro/mapreduce/AvroJob.java index 6d3639e..b857da3 100644 --- a/lang/java/mapred/src/main/java/org/apache/avro/mapreduce/AvroJob.java +++ b/lang/java/mapred/src/main/java/org/apache/avro/mapreduce/AvroJob.java @@ -36,7 +36,7 @@ import org.apache.hadoop.mapreduce.Job; * * <p>Suppose you would like to write a line count mapper that reads from a text file. If * instead of using a Text and IntWritable output value, you would like to use Avro data - * with a schema of <i>"string"</i> and <i>"int"</i>, respectively, you may parameterize + * with a schema of <i>"string"</i> and <i>"int"</i>, respectively, you may parametrize * your mapper with {@code AvroKey<CharSequence>} and {@code AvroValue<Integer>} * types. Then, use the <code>setMapOutputKeySchema()</code> and * <code>setMapOutputValueSchema()</code> methods to set writer schemas for the records http://git-wip-us.apache.org/repos/asf/avro/blob/4b69cb20/lang/java/mapred/src/test/java/org/apache/avro/mapred/TestAvroMultipleOutputs.java ---------------------------------------------------------------------- diff --git a/lang/java/mapred/src/test/java/org/apache/avro/mapred/TestAvroMultipleOutputs.java b/lang/java/mapred/src/test/java/org/apache/avro/mapred/TestAvroMultipleOutputs.java index 98205ba..6d57630 100644 --- a/lang/java/mapred/src/test/java/org/apache/avro/mapred/TestAvroMultipleOutputs.java +++ b/lang/java/mapred/src/test/java/org/apache/avro/mapred/TestAvroMultipleOutputs.java @@ -243,7 +243,7 @@ public class TestAvroMultipleOutputs { @SuppressWarnings("deprecation") - // Test for a differnt schema output + // Test for a different schema output public void testProjection1() throws Exception { JobConf job = new JobConf(); Schema readerSchema = Schema.create(Schema.Type.STRING); @@ -271,7 +271,7 @@ public class TestAvroMultipleOutputs { } @SuppressWarnings("deprecation") - // Test for a differnt schema output + // Test for a different schema output public void testProjection_newmethods_1() throws Exception { JobConf job = new JobConf(); Schema readerSchema = Schema.create(Schema.Type.STRING); http://git-wip-us.apache.org/repos/asf/avro/blob/4b69cb20/lang/java/mapred/src/test/java/org/apache/avro/mapred/tether/TetherTask.java ---------------------------------------------------------------------- diff --git a/lang/java/mapred/src/test/java/org/apache/avro/mapred/tether/TetherTask.java b/lang/java/mapred/src/test/java/org/apache/avro/mapred/tether/TetherTask.java index f3eb638..e17de83 100644 --- a/lang/java/mapred/src/test/java/org/apache/avro/mapred/tether/TetherTask.java +++ b/lang/java/mapred/src/test/java/org/apache/avro/mapred/tether/TetherTask.java @@ -228,7 +228,7 @@ public abstract class TetherTask<IN,MID,OUT> { } void close() { - LOG.info("Closing the transciever"); + LOG.info("Closing the transceiver"); if (clientTransceiver != null) try { clientTransceiver.close(); http://git-wip-us.apache.org/repos/asf/avro/blob/4b69cb20/lang/java/maven-plugin/src/main/java/org/apache/avro/mojo/SchemaMojo.java ---------------------------------------------------------------------- diff --git a/lang/java/maven-plugin/src/main/java/org/apache/avro/mojo/SchemaMojo.java b/lang/java/maven-plugin/src/main/java/org/apache/avro/mojo/SchemaMojo.java index 9a84920..2ab84ed 100644 --- a/lang/java/maven-plugin/src/main/java/org/apache/avro/mojo/SchemaMojo.java +++ b/lang/java/maven-plugin/src/main/java/org/apache/avro/mojo/SchemaMojo.java @@ -65,7 +65,7 @@ public class SchemaMojo extends AbstractAvroMojo { // This is necessary to maintain backward-compatibility. If there are // no imported files then isolate the schemas from each other, otherwise - // allow them to share a single schema so resuse and sharing of schema + // allow them to share a single schema so reuse and sharing of schema // is possible. if (imports == null) { schema = new Schema.Parser().parse(src); http://git-wip-us.apache.org/repos/asf/avro/blob/4b69cb20/lang/java/maven-plugin/src/test/java/org/apache/avro/mojo/AbstractAvroMojoTest.java ---------------------------------------------------------------------- diff --git a/lang/java/maven-plugin/src/test/java/org/apache/avro/mojo/AbstractAvroMojoTest.java b/lang/java/maven-plugin/src/test/java/org/apache/avro/mojo/AbstractAvroMojoTest.java index 2348781..d0c98fc 100644 --- a/lang/java/maven-plugin/src/test/java/org/apache/avro/mojo/AbstractAvroMojoTest.java +++ b/lang/java/maven-plugin/src/test/java/org/apache/avro/mojo/AbstractAvroMojoTest.java @@ -23,7 +23,7 @@ import java.util.List; import org.apache.maven.plugin.testing.AbstractMojoTestCase; /** - * Base class for all Arvo mojo test classes. + * Base class for all Avro mojo test classes. * * @author saden */ http://git-wip-us.apache.org/repos/asf/avro/blob/4b69cb20/lang/java/tools/src/test/java/org/apache/avro/tool/TestDataFileTools.java ---------------------------------------------------------------------- diff --git a/lang/java/tools/src/test/java/org/apache/avro/tool/TestDataFileTools.java b/lang/java/tools/src/test/java/org/apache/avro/tool/TestDataFileTools.java index 0270b71..7232e9c 100644 --- a/lang/java/tools/src/test/java/org/apache/avro/tool/TestDataFileTools.java +++ b/lang/java/tools/src/test/java/org/apache/avro/tool/TestDataFileTools.java @@ -229,7 +229,7 @@ public class TestDataFileTools { @Test public void testDifferentSeparatorsBetweenJsonRecords() throws Exception { File outFile = writeToAvroFile( - "seperators", + "separators", "{ \"type\":\"array\", \"items\":\"int\" }", "[] [] []\n[][3] "); assertEquals(5, countRecords(outFile));
