Package org.opennms.netmgt.flows.elastic
Class FlowDocument
- java.lang.Object
-
- org.opennms.netmgt.flows.elastic.FlowDocument
-
public class FlowDocument extends java.lang.ObjectMember variables are sorted by the value of the @SerializedName annotation.
-
-
Constructor Summary
Constructors Constructor Description FlowDocument()FlowDocument(Flow flow)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description voidaddHost(java.lang.String host)static EnrichedFlowbuildEnrichedFlow(FlowDocument flowDocument)static FlowDocumentfrom(Flow flow)java.lang.StringgetApplication()java.lang.LonggetBytes()longgetClockCorrection()java.lang.StringgetConvoKey()java.lang.LonggetDeltaSwitched()DirectiongetDirection()java.lang.IntegergetDscp()java.lang.StringgetDstAddr()java.lang.StringgetDstAddrHostname()java.lang.LonggetDstAs()LocalitygetDstLocality()java.lang.IntegergetDstMaskLen()java.lang.IntegergetDstPort()java.lang.IntegergetEcn()java.lang.IntegergetEngineId()java.lang.IntegergetEngineType()java.lang.LonggetFirstSwitched()FlowgetFlow()LocalitygetFlowLocality()intgetFlowRecords()longgetFlowSeqNum()java.lang.StringgetHost()java.util.Set<java.lang.String>getHosts()java.lang.IntegergetInputSnmp()java.lang.IntegergetIpProtocolVersion()java.lang.LonggetLastSwitched()java.lang.StringgetLocation()NetflowVersiongetNetflowVersion()java.lang.StringgetNextHop()java.lang.StringgetNextHopHostname()NodeDocumentgetNodeDst()NodeDocumentgetNodeExporter()NodeDocumentgetNodeSrc()java.lang.IntegergetOutputSnmp()java.lang.LonggetPackets()java.lang.IntegergetProtocol()SamplingAlgorithmgetSamplingAlgorithm()java.lang.DoublegetSamplingInterval()java.lang.StringgetSrcAddr()java.lang.StringgetSrcAddrHostname()java.lang.LonggetSrcAs()LocalitygetSrcLocality()java.lang.IntegergetSrcMaskLen()java.lang.IntegergetSrcPort()java.lang.IntegergetTcpFlags()longgetTimestamp()java.lang.IntegergetTos()java.lang.IntegergetVersion()java.lang.StringgetVlan()voidsetApplication(java.lang.String application)voidsetBytes(java.lang.Long bytes)voidsetClockCorrection(long clockCorrection)voidsetConvoKey(java.lang.String convoKey)voidsetDeltaSwitched(java.lang.Long deltaSwitched)voidsetDirection(Direction direction)voidsetDstAddr(java.lang.String dstAddr)voidsetDstAddrHostname(java.lang.String dstAddrHostname)voidsetDstAs(java.lang.Long dstAs)voidsetDstLocality(Locality dstLocality)voidsetDstMaskLen(java.lang.Integer dstMaskLen)voidsetDstPort(java.lang.Integer dstPort)voidsetEngineId(java.lang.Integer engineId)voidsetEngineType(java.lang.Integer engineType)voidsetFirstSwitched(java.lang.Long firstSwitched)voidsetFlow(Flow flow)voidsetFlowLocality(Locality flowLocality)voidsetFlowRecords(int flowRecords)voidsetFlowSeqNum(long flowSeqNum)voidsetHost(java.lang.String host)voidsetHosts(java.util.Set<java.lang.String> hosts)voidsetInputSnmp(java.lang.Integer inputSnmp)voidsetIpProtocolVersion(java.lang.Integer ipProtocolVersion)voidsetLastSwitched(java.lang.Long lastSwitched)voidsetLocation(java.lang.String location)voidsetNetflowVersion(NetflowVersion netflowVersion)voidsetNextHop(java.lang.String nextHop)voidsetNextHopHostname(java.lang.String nextHopHostname)voidsetNodeDst(NodeDocument nodeDst)voidsetNodeExporter(NodeDocument nodeExporter)voidsetNodeSrc(NodeDocument nodeSrc)voidsetOutputSnmp(java.lang.Integer outputSnmp)voidsetPackets(java.lang.Long packets)voidsetProtocol(java.lang.Integer protocol)voidsetSamplingAlgorithm(SamplingAlgorithm samplingAlgorithm)voidsetSamplingInterval(java.lang.Double samplingInterval)voidsetSrcAddr(java.lang.String srcAddr)voidsetSrcAddrHostname(java.lang.String srcAddrHostname)voidsetSrcAs(java.lang.Long srcAs)voidsetSrcLocality(Locality srcLocality)voidsetSrcMaskLen(java.lang.Integer srcMaskLen)voidsetSrcPort(java.lang.Integer srcPort)voidsetTcpFlags(java.lang.Integer tcpFlags)voidsetTimestamp(long timestamp)voidsetTos(java.lang.Integer tos)voidsetVersion(java.lang.Integer version)voidsetVlan(java.lang.String vlan)
-
-
-
Constructor Detail
-
FlowDocument
public FlowDocument(Flow flow)
-
FlowDocument
public FlowDocument()
-
-
Method Detail
-
addHost
public void addHost(java.lang.String host)
-
getFlow
public Flow getFlow()
-
setFlow
public void setFlow(Flow flow)
-
getTimestamp
public long getTimestamp()
-
setTimestamp
public void setTimestamp(long timestamp)
-
getClockCorrection
public long getClockCorrection()
-
setClockCorrection
public void setClockCorrection(long clockCorrection)
-
getVersion
public java.lang.Integer getVersion()
-
setVersion
public void setVersion(java.lang.Integer version)
-
getHost
public java.lang.String getHost()
-
setHost
public void setHost(java.lang.String host)
-
getHosts
public java.util.Set<java.lang.String> getHosts()
-
setHosts
public void setHosts(java.util.Set<java.lang.String> hosts)
-
getLocation
public java.lang.String getLocation()
-
setLocation
public void setLocation(java.lang.String location)
-
getApplication
public java.lang.String getApplication()
-
setApplication
public void setApplication(java.lang.String application)
-
getBytes
public java.lang.Long getBytes()
-
setBytes
public void setBytes(java.lang.Long bytes)
-
getConvoKey
public java.lang.String getConvoKey()
-
setConvoKey
public void setConvoKey(java.lang.String convoKey)
-
getDirection
public Direction getDirection()
-
setDirection
public void setDirection(Direction direction)
-
getDstAddr
public java.lang.String getDstAddr()
-
setDstAddr
public void setDstAddr(java.lang.String dstAddr)
-
getDstAddrHostname
public java.lang.String getDstAddrHostname()
-
setDstAddrHostname
public void setDstAddrHostname(java.lang.String dstAddrHostname)
-
getDstAs
public java.lang.Long getDstAs()
-
setDstAs
public void setDstAs(java.lang.Long dstAs)
-
getDstLocality
public Locality getDstLocality()
-
setDstLocality
public void setDstLocality(Locality dstLocality)
-
getDstMaskLen
public java.lang.Integer getDstMaskLen()
-
setDstMaskLen
public void setDstMaskLen(java.lang.Integer dstMaskLen)
-
getDstPort
public java.lang.Integer getDstPort()
-
setDstPort
public void setDstPort(java.lang.Integer dstPort)
-
getEngineId
public java.lang.Integer getEngineId()
-
setEngineId
public void setEngineId(java.lang.Integer engineId)
-
getEngineType
public java.lang.Integer getEngineType()
-
setEngineType
public void setEngineType(java.lang.Integer engineType)
-
getFirstSwitched
public java.lang.Long getFirstSwitched()
-
setFirstSwitched
public void setFirstSwitched(java.lang.Long firstSwitched)
-
getFlowLocality
public Locality getFlowLocality()
-
setFlowLocality
public void setFlowLocality(Locality flowLocality)
-
getFlowRecords
public int getFlowRecords()
-
setFlowRecords
public void setFlowRecords(int flowRecords)
-
getFlowSeqNum
public long getFlowSeqNum()
-
setFlowSeqNum
public void setFlowSeqNum(long flowSeqNum)
-
getInputSnmp
public java.lang.Integer getInputSnmp()
-
setInputSnmp
public void setInputSnmp(java.lang.Integer inputSnmp)
-
getIpProtocolVersion
public java.lang.Integer getIpProtocolVersion()
-
setIpProtocolVersion
public void setIpProtocolVersion(java.lang.Integer ipProtocolVersion)
-
getLastSwitched
public java.lang.Long getLastSwitched()
-
setLastSwitched
public void setLastSwitched(java.lang.Long lastSwitched)
-
getNextHop
public java.lang.String getNextHop()
-
setNextHop
public void setNextHop(java.lang.String nextHop)
-
getNextHopHostname
public java.lang.String getNextHopHostname()
-
setNextHopHostname
public void setNextHopHostname(java.lang.String nextHopHostname)
-
getOutputSnmp
public java.lang.Integer getOutputSnmp()
-
setOutputSnmp
public void setOutputSnmp(java.lang.Integer outputSnmp)
-
getPackets
public java.lang.Long getPackets()
-
setPackets
public void setPackets(java.lang.Long packets)
-
getProtocol
public java.lang.Integer getProtocol()
-
setProtocol
public void setProtocol(java.lang.Integer protocol)
-
getSamplingAlgorithm
public SamplingAlgorithm getSamplingAlgorithm()
-
setSamplingAlgorithm
public void setSamplingAlgorithm(SamplingAlgorithm samplingAlgorithm)
-
getSamplingInterval
public java.lang.Double getSamplingInterval()
-
setSamplingInterval
public void setSamplingInterval(java.lang.Double samplingInterval)
-
getSrcAddr
public java.lang.String getSrcAddr()
-
setSrcAddr
public void setSrcAddr(java.lang.String srcAddr)
-
getSrcAddrHostname
public java.lang.String getSrcAddrHostname()
-
setSrcAddrHostname
public void setSrcAddrHostname(java.lang.String srcAddrHostname)
-
getSrcAs
public java.lang.Long getSrcAs()
-
setSrcAs
public void setSrcAs(java.lang.Long srcAs)
-
getSrcLocality
public Locality getSrcLocality()
-
setSrcLocality
public void setSrcLocality(Locality srcLocality)
-
getSrcMaskLen
public java.lang.Integer getSrcMaskLen()
-
setSrcMaskLen
public void setSrcMaskLen(java.lang.Integer srcMaskLen)
-
getSrcPort
public java.lang.Integer getSrcPort()
-
setSrcPort
public void setSrcPort(java.lang.Integer srcPort)
-
getTcpFlags
public java.lang.Integer getTcpFlags()
-
setTcpFlags
public void setTcpFlags(java.lang.Integer tcpFlags)
-
getDeltaSwitched
public java.lang.Long getDeltaSwitched()
-
setDeltaSwitched
public void setDeltaSwitched(java.lang.Long deltaSwitched)
-
getTos
public java.lang.Integer getTos()
-
setTos
public void setTos(java.lang.Integer tos)
-
getEcn
public java.lang.Integer getEcn()
-
getDscp
public java.lang.Integer getDscp()
-
getNetflowVersion
public NetflowVersion getNetflowVersion()
-
setNetflowVersion
public void setNetflowVersion(NetflowVersion netflowVersion)
-
getVlan
public java.lang.String getVlan()
-
setVlan
public void setVlan(java.lang.String vlan)
-
getNodeDst
public NodeDocument getNodeDst()
-
setNodeDst
public void setNodeDst(NodeDocument nodeDst)
-
getNodeExporter
public NodeDocument getNodeExporter()
-
setNodeExporter
public void setNodeExporter(NodeDocument nodeExporter)
-
getNodeSrc
public NodeDocument getNodeSrc()
-
setNodeSrc
public void setNodeSrc(NodeDocument nodeSrc)
-
from
public static FlowDocument from(Flow flow)
-
buildEnrichedFlow
public static EnrichedFlow buildEnrichedFlow(FlowDocument flowDocument)
-
-