com.mozilla.secops.amo

Class Amo

java.lang.Object

com.mozilla.secops.amo.Amo

All Implemented Interfaces:

Serializable

public class Amo
extends Object
implements Serializable

Various heuristics for AMO analysis

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	Amo.AmoOptions Runtime options for Amo pipeline.

Constructor Summary

Constructors

Constructor and Description
Amo()

Method Summary

Modifier and Type	Method and Description
static String	buildConfigurationTick(Amo.AmoOptions options) Build a configuration tick for Amo given pipeline options
static org.apache.beam.sdk.values.PCollection<Alert>	executePipeline(org.apache.beam.sdk.Pipeline p, org.apache.beam.sdk.values.PCollection<String> input, Amo.AmoOptions options) Execute AMO pipeline
static void	main(String[] args) Entry point for Beam pipeline.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Amo

public Amo()

Method Detail

executePipeline

public static org.apache.beam.sdk.values.PCollection<Alert> executePipeline(org.apache.beam.sdk.Pipeline p,
                                                                            org.apache.beam.sdk.values.PCollection<String> input,
                                                                            Amo.AmoOptions options)
                                                                     throws IOException

Execute AMO pipeline

Parameters:

p - Pipeline

input - Input collection

options - AmoOptions

Returns:

Collection of Alert objects

Throws:

IOException - IOException

buildConfigurationTick

public static String buildConfigurationTick(Amo.AmoOptions options)
                                     throws IOException

Build a configuration tick for Amo given pipeline options

Parameters:

options - Pipeline options

Returns:

String

Throws:

IOException - IOException

main

public static void main(String[] args)
                 throws IOException

Entry point for Beam pipeline.

Parameters:

args - Runtime arguments.

Throws:

IOException - IOException