dcae-analytics-cdap-plugins/src/main/java/org/onap/dcae/apod/analytics/cdap/plugins/domain/schema/dmaap/DMaaPSourceOutputSchema.java

   1 /*
   2  * ===============================LICENSE_START======================================
   3  *  dcae-analytics
   4  * ================================================================================
   5  *    Copyright © 2017 AT&T Intellectual Property. All rights reserved.
   6  * ================================================================================
   7  *  Licensed under the Apache License, Version 2.0 (the "License");
   8  *  you may not use this file except in compliance with the License.
   9  *   You may obtain a copy of the License at
  10  *
  11  *          http://www.apache.org/licenses/LICENSE-2.0
  12  *
  13  *  Unless required by applicable law or agreed to in writing, software
  14  *  distributed under the License is distributed on an "AS IS" BASIS,
  15  *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  16  *  See the License for the specific language governing permissions and
  17  *  limitations under the License.
  18  *  ============================LICENSE_END===========================================
  19  */
  20
  21 package org.onap.dcae.apod.analytics.cdap.plugins.domain.schema.dmaap;
  22
  23 import co.cask.cdap.api.data.schema.Schema;
  24 import org.onap.dcae.apod.analytics.cdap.plugins.common.PluginSchema;
  25
  26 /**
  27  * Output Schema for DMaaP MR Source Plugin
  28  *
  29  * @author Rajiv Singla . Creation Date: 1/25/2017.
  30  */
  31 public enum DMaaPSourceOutputSchema implements PluginSchema {
  32
  33     TIMESTAMP("ts"),
  34     RESPONSE_CODE("responseCode"),
  35     RESPONSE_MESSAGE("responseMessage"),
  36     FETCHED_MESSAGE("message");
  37
  38     private String schemaColumnName;
  39
  40     DMaaPSourceOutputSchema(String schemaColumnName) {
  41         this.schemaColumnName = schemaColumnName;
  42     }
  43
  44     @Override
  45     public String getSchemaColumnName() {
  46         return schemaColumnName;
  47     }
  48
  49     public static Schema getSchema() {
  50         return Schema.recordOf(
  51                 "DMaaPMRSourcePluginResponse",
  52                 Schema.Field.of(TIMESTAMP.getSchemaColumnName(), Schema.of(Schema.Type.LONG)),
  53                 Schema.Field.of(RESPONSE_CODE.getSchemaColumnName(), Schema.of(Schema.Type.INT)),
  54                 Schema.Field.of(RESPONSE_MESSAGE.getSchemaColumnName(), Schema.of(Schema.Type.STRING)),
  55                 Schema.Field.of(FETCHED_MESSAGE.getSchemaColumnName(), Schema.of(Schema.Type.STRING))
  56         );
  57     }
  58
  59 }