<commit_before>package com.bwsw.sj.engine.core.entities

import com.fasterxml.jackson.annotation.JsonSubTypes.Type
import com.fasterxml.jackson.annotation.{JsonSubTypes, JsonTypeInfo}

/**
 * Represents a message envelope that is received by an Executor for each message
 * that is received from a partition of a specific input (kafka, t-stream, elasticsearch, jdbc)
 */

@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, property = "streamType")
@JsonSubTypes(Array(
  new Type(value = classOf[TStreamEnvelope], name = "stream.t-stream"),
  new Type(value = classOf[KafkaEnvelope], name = "stream.kafka"),
  new Type(value = classOf[EsEnvelope], name = "elasticsearch-output"),
  new Type(value = classOf[JdbcEnvelope], name = "jdbc-output")
))
class Envelope() extends Serializable {
  protected var streamType: String = null
  var stream: String = null
  var partition: Int = 0
  var tags: Array[String] = Array()
  var empty: Boolean = true

  def isEmpty() = {
    streamType == null
  }
}<commit_msg>SJ-2612 remove "empty" field<commit_after>package com.bwsw.sj.engine.core.entities

import com.fasterxml.jackson.annotation.JsonSubTypes.Type
import com.fasterxml.jackson.annotation.{JsonIgnore, JsonSubTypes, JsonTypeInfo}

/**
 * Represents a message envelope that is received by an Executor for each message
 * that is received from a partition of a specific input (kafka, t-stream, elasticsearch, jdbc)
 */

@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, property = "streamType")
@JsonSubTypes(Array(
  new Type(value = classOf[TStreamEnvelope], name = "stream.t-stream"),
  new Type(value = classOf[KafkaEnvelope], name = "stream.kafka"),
  new Type(value = classOf[EsEnvelope], name = "elasticsearch-output"),
  new Type(value = classOf[JdbcEnvelope], name = "jdbc-output")
))
class Envelope() extends Serializable {
  protected var streamType: String = null
  var stream: String = null
  var partition: Int = 0
  var tags: Array[String] = Array()

  @JsonIgnore()
  def isEmpty() = {
    streamType == null
  }
}
{'fraction_non_alphanumeric': 0.11884634510193934, 'fraction_numerical': 0.0029835902536051715, 'mean_word_length': 4.883040935672515, 'pattern_counts': {'":': 0, '<': 3, '<?xml version=': 0, '>': 3, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 4}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '5531201', 'n_tokens_mistral': 629, 'n_tokens_neox': 617, 'n_words': 177}