Kafka hdfs flume 数据采集实验

/* * Copyright (c) 2015, 2020, Oracle and/or its affiliates. * * This program is free software; you can redistribute it and/or modify it under * the terms of the GNU General Public License, version 2.0, as published by the * Free Software Foundation. * * This program is also distributed with certain software (including but not * limited to OpenSSL) that is licensed under separate terms, as designated in a * particular file or component or in included license documentation. The * authors of MySQL hereby grant you an additional permission to link the * program and your derivative works with the separately licensed software that * they have included with MySQL. * * Without limiting anything contained in the foregoing, this file, which is * part of MySQL Connector/J, is also subject to the Universal FOSS Exception, * version 1.0, a copy of which can be found at * http://oss.oracle.com/licenses/universal-foss-exception. * * This program is distributed in the hope that it will be useful, but WITHOUT * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS * FOR A PARTICULAR PURPOSE. See the GNU General Public License, version 2.0, * for more details. * * You should have received a copy of the GNU General Public License along with * this program; if not, write to the Free Software Foundation, Inc., * 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA */ package com.mysql.cj.x.protobuf; // Generated by the protocol buffer compiler. DO NOT EDIT! // source: mysqlx_crud.proto @SuppressWarnings({ "deprecation" }) public final class MysqlxCrud { private MysqlxCrud() {} public static void registerAllExtensions( com.google.protobuf.ExtensionRegistryLite registry) { } public static void registerAllExtensions( com.google.protobuf.ExtensionRegistry registry) { registerAllExtensions( (com.google.protobuf.ExtensionRegistryLite) registry); } /** * <pre> * DataModel to use for filters, names, ... * </pre> * * Protobuf enum {@code Mysqlx.Crud.DataModel} */ public enum DataModel implements com.google.protobuf.ProtocolMessageEnum { /** * <code>DOCUMENT = 1;</code> */ DOCUMENT(1), /** * <code>TABLE = 2;</code> */ TABLE(2), ; /** * <code>DOCUMENT = 1;</code> */ public static final int DOCUMENT_VALUE = 1; /** * <code>TABLE = 2;</code> */ public static final int TABLE_VALUE = 2; public final int getNumber() { return value; } /** * @param value The numeric wire value of the corresponding enum entry. * @return The enum associated with the given numeric wire value. * @deprecated Use {@link #forNumber(int)} instead. */ @java.lang.Deprecated public static DataModel valueOf(int value) { return forNumber(value); } /** * @param value The numeric wire value of the corresponding enum entry. * @return The enum associated with the given numeric wire value. */ public static DataModel forNumber(int value) { switch (value) { case 1: return DOCUMENT; case 2: return TABLE; default: return null; } } public static com.google.protobuf.Internal.EnumLiteMap<DataModel> internalGetValueMap() { return internalValueMap; } private static final com.google.protobuf.Internal.EnumLiteMap< DataModel> internalValueMap = new com.google.protobuf.Internal.EnumLiteMap<DataModel>() { public DataModel findValueByNumber(int number) { return DataModel.forNumber(number); } }; public final com.google.protobuf.Descriptors.EnumValueDescriptor getValueDescriptor() { return getDescriptor().getValues().get(ordinal()); } public final com.google.protobuf.Descriptors.EnumDescriptor getDescriptorForType() { return getDescriptor(); } public static final com.google.protobuf.Descriptors.EnumDescriptor getDescriptor() { return com.mysql.cj.x.protobuf.MysqlxCrud.getDescriptor().getEnumTypes().get(0); } private static final DataModel[] VALUES = values(); public static DataModel valueOf( com.google.protobuf.Descriptors.EnumValueDescriptor desc) { if (desc.getType() != getDescriptor()) { throw new java.lang.IllegalArgumentException( "EnumValueDescriptor is not for this type."); } return VALUES[desc.getIndex()]; } private final int value; private DataModel(int value) { this.value = value; } // @@protoc_insertion_point(enum_scope:Mysqlx.Crud.DataModel) } /** * <pre> * ViewAlgorithm defines how MySQL Server processes the view * </pre> * * Protobuf enum {@code Mysqlx.Crud.ViewAlgorithm} */ public enum ViewAlgorithm implements com.google.protobuf.ProtocolMessageEnum { /** * <pre> * MySQL chooses which algorithm to use * </pre> * * <code>UNDEFINED = 1;</code> */ UNDEFINED(1), /** * <pre> * the text of a statement that refers to the view and the view definition are merged * </pre> * * <code>MERGE = 2;</code> */ MERGE(2), /** * <pre> * the view are retrieved into a temporary table * </pre> * * <code>TEMPTABLE = 3;</code> */ TEMPTABLE(3), ; /** * <pre> * MySQL chooses which algorithm to use * </pre> * * <code>UNDEFINED = 1;</code> */ public static final int UNDEFINED_VALUE = 1; /** * <pre> * the text of a statement that refers to the view and the view definition are merged * </pre> * * <code>MERGE = 2;</code> */ public static final int MERGE_VALUE = 2; /** * <pre> * the view are retrieved into a temporary table * </pre> * * <code>TEMPTABLE = 3;</code> */ public static final int TEMPTABLE_VALUE = 3; public final int getNumber() { return value; } /** * @param value The numeric wire value of the corresponding enum entry. * @return The enum associated with the given numeric wire value. * @deprecated Use {@link #forNumber(int)} instead. */ @java.lang.Deprecated public static ViewAlgorithm valueOf(int value) { return forNumber(value); } /** * @param value The numeric wire value of the corresponding enum entry. * @return The enum associated with the given numeric wire value. */ public static ViewAlgorithm forNumber(int value) { switch (value) { case 1: return UNDEFINED; case 2: return MERGE; case 3: return TEMPTABLE; default: return null; } } public static com.google.protobuf.Internal.EnumLiteMap<ViewAlgorithm> internalGetValueMap() { return internalValueMap; } private static final com.google.protobuf.Internal.EnumLiteMap< ViewAlgorithm> internalValueMap = new com.google.protobuf.Internal.EnumLiteMap<ViewAlgorithm>() { public ViewAlgorithm findValueByNumber(int number) { return ViewAlgorithm.forNumber(number); } }; public final com.google.protobuf.Descriptors.EnumValueDescriptor getValueDescriptor() { return getDescriptor().getValues().get(ordinal()); } public final com.google.protobuf.Descriptors.EnumDescriptor getDescriptorForType() { return getDescriptor(); } public static final com.google.protobuf.Descriptors.EnumDescriptor getDescriptor() { return com.mysql.cj.x.protobuf.MysqlxCrud.getDescriptor().getEnumTypes().get(1); } private static final ViewAlgorithm[] VALUES = values(); public static ViewAlgorithm valueOf( com.google.protobuf.Descriptors.EnumValueDescriptor desc) { if (desc.getType() != getDescriptor()) { throw