CoderProperties (Google Cloud Dataflow SDK 1.9.1 API)

Google Cloud Dataflow SDK for Java, version 1.9.1

com.google.cloud.dataflow.sdk.testing

Class CoderProperties



  • public class CoderProperties
    extends Object
    Properties for use in Coder tests. These are implemented with junit assertions rather than as predicates for the sake of error messages.

    We serialize and deserialize the coder to make sure that any state information required by the coder is preserved. This causes tests written such that coders that lose information during serialization or change state during encoding/decoding will fail.

    • Field Detail

      • ALL_CONTEXTS

        public static final List<Coder.Context> ALL_CONTEXTS
        All the contexts, for use in test cases.
    • Constructor Detail

      • CoderProperties

        public CoderProperties()
    • Method Detail

      • coderDeterministic

        public static <T> void coderDeterministic(Coder<T> coder,
                                                  T value1,
                                                  T value2)
                                           throws Exception
        Verifies that for the given Coder<T>, and values of type T, if the values are equal then the encoded bytes are equal, in any Coder.Context.
        Throws:
        Exception
      • coderDeterministicInContext

        public static <T> void coderDeterministicInContext(Coder<T> coder,
                                                           Coder.Context context,
                                                           T value1,
                                                           T value2)
                                                    throws Exception
        Verifies that for the given Coder<T>, Coder.Context, and values of type T, if the values are equal then the encoded bytes are equal.
        Throws:
        Exception
      • coderDecodeEncodeEqual

        public static <T> void coderDecodeEncodeEqual(Coder<T> coder,
                                                      T value)
                                               throws Exception
        Verifies that for the given Coder<T>, and value of type T, encoding followed by decoding yields an equal value of type T, in any Coder.Context.
        Throws:
        Exception
      • coderDecodeEncodeEqualInContext

        public static <T> void coderDecodeEncodeEqualInContext(Coder<T> coder,
                                                               Coder.Context context,
                                                               T value)
                                                        throws Exception
        Verifies that for the given Coder<T>, Coder.Context, and value of type T, encoding followed by decoding yields an equal value of type T.
        Throws:
        Exception
      • coderDecodeEncodeContentsEqual

        public static <T,CollectionT extends Collection<T>> void coderDecodeEncodeContentsEqual(Coder<CollectionT> coder,
                                                                                                CollectionT value)
                                                                                         throws Exception
        Verifies that for the given Coder<Collection<T>>, and value of type Collection<T>, encoding followed by decoding yields an equal value of type Collection<T>, in any Coder.Context.
        Throws:
        Exception
      • coderDecodeEncodeContentsEqualInContext

        public static <T,CollectionT extends Collection<T>> void coderDecodeEncodeContentsEqualInContext(Coder<CollectionT> coder,
                                                                                                         Coder.Context context,
                                                                                                         CollectionT value)
                                                                                                  throws Exception
        Verifies that for the given Coder<Collection<T>>, and value of type Collection<T>, encoding followed by decoding yields an equal value of type Collection<T>, in the given Coder.Context.
        Throws:
        Exception
      • coderDecodeEncodeContentsInSameOrder

        public static <T,IterableT extends Iterable<T>> void coderDecodeEncodeContentsInSameOrder(Coder<IterableT> coder,
                                                                                                  IterableT value)
                                                                                           throws Exception
        Verifies that for the given Coder<Collection<T>>, and value of type Collection<T>, encoding followed by decoding yields an equal value of type Collection<T>, in any Coder.Context.
        Throws:
        Exception
      • coderDecodeEncodeContentsInSameOrderInContext

        public static <T,IterableT extends Iterable<T>> void coderDecodeEncodeContentsInSameOrderInContext(Coder<IterableT> coder,
                                                                                                           Coder.Context context,
                                                                                                           IterableT value)
                                                                                                    throws Exception
        Verifies that for the given Coder<Iterable<T>>, and value of type Iterable<T>, encoding followed by decoding yields an equal value of type Collection<T>, in the given Coder.Context.
        Throws:
        Exception
      • coderSerializable

        public static <T> void coderSerializable(Coder<T> coder)
      • coderConsistentWithEquals

        public static <T> void coderConsistentWithEquals(Coder<T> coder,
                                                         T value1,
                                                         T value2)
                                                  throws Exception
        Throws:
        Exception
      • coderConsistentWithEqualsInContext

        public static <T> void coderConsistentWithEqualsInContext(Coder<T> coder,
                                                                  Coder.Context context,
                                                                  T value1,
                                                                  T value2)
                                                           throws Exception
        Throws:
        Exception
      • structuralValueConsistentWithEquals

        public static <T> void structuralValueConsistentWithEquals(Coder<T> coder,
                                                                   T value1,
                                                                   T value2)
                                                            throws Exception
        Throws:
        Exception
      • structuralValueConsistentWithEqualsInContext

        public static <T> void structuralValueConsistentWithEqualsInContext(Coder<T> coder,
                                                                            Coder.Context context,
                                                                            T value1,
                                                                            T value2)
                                                                     throws Exception
        Throws:
        Exception
      • coderDecodesBase64

        public static <T> void coderDecodesBase64(Coder<T> coder,
                                                  String base64Encoding,
                                                  T value)
                                           throws Exception
        Throws:
        Exception
      • coderEncodesBase64

        public static <T> void coderEncodesBase64(Coder<T> coder,
                                                  T value,
                                                  String base64Encoding)
                                           throws Exception
        Throws:
        Exception
      • coderDecodesBase64ContentsEqual

        public static <T,IterableT extends Iterable<T>> void coderDecodesBase64ContentsEqual(Coder<IterableT> coder,
                                                                                             String base64Encoding,
                                                                                             IterableT expected)
                                                                                      throws Exception
        Throws:
        Exception
      • coderDecodesBase64ContentsEqual

        public static <T,IterableT extends Iterable<T>> void coderDecodesBase64ContentsEqual(Coder<IterableT> coder,
                                                                                             List<String> base64Encodings,
                                                                                             List<IterableT> expected)
                                                                                      throws Exception
        Throws:
        Exception


Send feedback about...

Cloud Dataflow