@DefaultCoder(value=org.apache.beam.sdk.coders.AvroCoder.class) public static class SourceCorrelation.SourceData extends Object implements Serializable
AvroCoder
is used to guarantee certain uniqueness properties that are needed during
the Distinct
step. In this case Serializable does not guarantee us deterministic
encoding.
See also https://beam.apache.org/releases/javadoc/2.17.0/org/apache/beam/sdk/coders/Coder.html#verifyDeterministic--
Modifier and Type | Class and Description |
---|---|
static class |
SourceCorrelation.SourceData.SourceDataType
Source data types
|
Constructor and Description |
---|
SourceData() |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
Integer |
getAsn()
Get ASN
|
String |
getCity()
Get city
|
String |
getCountry()
Get country
|
String |
getIsp()
Get ISP
|
String |
getSourceAddress()
Get source address
|
SourceCorrelation.SourceData.SourceDataType |
getSourceDataType()
Get source data type
|
int |
hashCode() |
void |
setAsn(Integer asn)
Set ASN
|
void |
setCity(String city)
Set city
|
void |
setCountry(String country)
Set country
|
void |
setIsp(String isp)
Set ISP
|
void |
setSourceAddress(String sourceAddress)
Set source address
|
void |
setSourceDataType(SourceCorrelation.SourceData.SourceDataType type)
Set source data type
|
public SourceCorrelation.SourceData.SourceDataType getSourceDataType()
public void setSourceDataType(SourceCorrelation.SourceData.SourceDataType type)
type
- SourceDataTypepublic String getSourceAddress()
public void setSourceAddress(String sourceAddress)
sourceAddress
- Stringpublic String getCity()
public void setCity(String city)
city
- Stringpublic String getCountry()
public void setCountry(String country)
country
- Stringpublic Integer getAsn()
public void setAsn(Integer asn)
asn
- Integerpublic String getIsp()
public void setIsp(String isp)
isp
- StringCopyright © 2022. All rights reserved.